From 1af0bbf7eed53db863d413a1862ac1ded3f29ffc Mon Sep 17 00:00:00 2001 From: Matthias Wachs Date: Fri, 12 Aug 2011 23:11:07 +0000 Subject: --- src/transport/test_transport_api_reliability.c | 22 +++++++++++++--------- 1 file changed, 13 insertions(+), 9 deletions(-) (limited to 'src') diff --git a/src/transport/test_transport_api_reliability.c b/src/transport/test_transport_api_reliability.c index 273a69526..37395ad0f 100644 --- a/src/transport/test_transport_api_reliability.c +++ b/src/transport/test_transport_api_reliability.c @@ -44,20 +44,11 @@ #define START_ARM GNUNET_YES -/** - * Note that this value must not significantly exceed - * 'MAX_PENDING' in 'gnunet-service-transport.c', otherwise - * messages may be dropped even for a reliable transport. - */ -#define TOTAL_MSGS (1024 * 2) - /** * How long until we give up on transmitting the message? */ #define TIMEOUT GNUNET_TIME_relative_multiply (GNUNET_TIME_UNIT_SECONDS, 1500) -#define MTYPE 12345 - static int ok; static GNUNET_SCHEDULER_TaskIdentifier die_task; @@ -76,6 +67,15 @@ char * cfg_file_p2; * Testcase specific declarations */ +/** + * Note that this value must not significantly exceed + * 'MAX_PENDING' in 'gnunet-service-transport.c', otherwise + * messages may be dropped even for a reliable transport. + */ +#define TOTAL_MSGS (1024 * 2) + +#define MTYPE 12345 + struct TestMessage { struct GNUNET_MessageHeader header; @@ -309,6 +309,10 @@ notify_ready (void *cls, size_t size, void *buf) ret); } total_bytes += ret; + if (n == TOTAL_MSGS) + { + GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,"All messages sent\n"); + } return ret; } -- cgit v1.2.3