[Top][All Lists]
[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]
[GNUnet-SVN] r12982 - gnunet/src/transport
From: |
gnunet |
Subject: |
[GNUnet-SVN] r12982 - gnunet/src/transport |
Date: |
Tue, 14 Sep 2010 12:46:48 +0200 |
Author: wachs
Date: 2010-09-14 12:46:48 +0200 (Tue, 14 Sep 2010)
New Revision: 12982
Modified:
gnunet/src/transport/test_transport_api_reliability.c
Log:
Added some information when test fails
Modified: gnunet/src/transport/test_transport_api_reliability.c
===================================================================
--- gnunet/src/transport/test_transport_api_reliability.c 2010-09-14
08:47:08 UTC (rev 12981)
+++ gnunet/src/transport/test_transport_api_reliability.c 2010-09-14
10:46:48 UTC (rev 12982)
@@ -98,7 +98,11 @@
static char * key_file_p2;
static char * cert_file_p2;
+static int msg_scheduled;
+static int msg_sent;
+static int msg_recv;
+
#if VERBOSE
#define OKPP do { ok++; fprintf (stderr, "Now at stage %u at %s:%u\n", ok,
__FILE__, __LINE__); } while (0)
#else
@@ -148,6 +152,8 @@
end_badly (void *cls,
const struct GNUNET_SCHEDULER_TaskContext *tc)
{
+ GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
+ "Reliability failed: \nLast message scheduled %u of %u \nLast
message sent %u \nLast message received %u \n ", msg_scheduled, TOTAL_MSGS,
msg_sent, msg_recv);
GNUNET_break (0);
GNUNET_TRANSPORT_disconnect (p1.th);
GNUNET_TRANSPORT_disconnect (p2.th);
@@ -190,6 +196,7 @@
s = get_size (n);
if (MTYPE != ntohs (message->type))
return;
+ msg_recv++;
if (ntohs (message->size) != s)
{
GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
@@ -273,6 +280,7 @@
hdr.header.size = htons (s);
hdr.header.type = htons (MTYPE);
hdr.num = htonl (n);
+ msg_sent = n;
memcpy (&cbuf[ret], &hdr, sizeof (struct TestMessage));
ret += sizeof (struct TestMessage);
memset (&cbuf[ret], n, s - sizeof (struct TestMessage));
@@ -293,11 +301,14 @@
}
while (size - ret >= s);
if (n < TOTAL_MSGS)
+ {
GNUNET_TRANSPORT_notify_transmit_ready (p2.th,
&p1.id,
s, 0, TIMEOUT,
¬ify_ready,
NULL);
+ msg_scheduled = n;
+ }
if (n % 5000 == 0)
{
GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
[Prev in Thread] |
Current Thread |
[Next in Thread] |
- [GNUnet-SVN] r12982 - gnunet/src/transport,
gnunet <=