aboutsummaryrefslogtreecommitdiff
path: root/src/transport/test_transport_api_unreliability.c
diff options
context:
space:
mode:
authorMatthias Wachs <wachs@net.in.tum.de>2011-06-20 09:05:51 +0000
committerMatthias Wachs <wachs@net.in.tum.de>2011-06-20 09:05:51 +0000
commit1ad257905ce4a45bbe59b08ea52a3c3c6622da5d (patch)
tree5ebee625c994338f1fd592cae6c1d75af1909603 /src/transport/test_transport_api_unreliability.c
parent61a008c4e471cd5081d5c2871949da779246a868 (diff)
downloadgnunet-1ad257905ce4a45bbe59b08ea52a3c3c6622da5d.tar.gz
gnunet-1ad257905ce4a45bbe59b08ea52a3c3c6622da5d.zip
Diffstat (limited to 'src/transport/test_transport_api_unreliability.c')
-rw-r--r--src/transport/test_transport_api_unreliability.c21
1 files changed, 14 insertions, 7 deletions
diff --git a/src/transport/test_transport_api_unreliability.c b/src/transport/test_transport_api_unreliability.c
index 90a53c2b8..0cfc036de 100644
--- a/src/transport/test_transport_api_unreliability.c
+++ b/src/transport/test_transport_api_unreliability.c
@@ -164,7 +164,8 @@ end ()
164 } 164 }
165 } 165 }
166 166
167 GNUNET_SCHEDULER_cancel (die_task); 167 if (GNUNET_SCHEDULER_NO_TASK != tct)
168 GNUNET_SCHEDULER_cancel (die_task);
168 die_task = GNUNET_SCHEDULER_NO_TASK; 169 die_task = GNUNET_SCHEDULER_NO_TASK;
169#if VERBOSE 170#if VERBOSE
170 GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Disconnecting from transports!\n"); 171 GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Disconnecting from transports!\n");
@@ -325,7 +326,8 @@ notify_receive (void *cls,
325 ntohl(hdr->num), s, 326 ntohl(hdr->num), s,
326 ntohs (message->size), 327 ntohs (message->size),
327 ntohl (hdr->num)); 328 ntohl (hdr->num));
328 GNUNET_SCHEDULER_cancel (die_task); 329 if (GNUNET_SCHEDULER_NO_TASK != die_task)
330 GNUNET_SCHEDULER_cancel (die_task);
329 die_task = GNUNET_SCHEDULER_add_now (&end_badly, NULL); 331 die_task = GNUNET_SCHEDULER_add_now (&end_badly, NULL);
330 return; 332 return;
331 } 333 }
@@ -338,7 +340,8 @@ notify_receive (void *cls,
338 GNUNET_log (GNUNET_ERROR_TYPE_ERROR, 340 GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
339 "Expected message %u with bits %u, but body did not match\n", 341 "Expected message %u with bits %u, but body did not match\n",
340 ntohl(hdr->num), (unsigned char) n); 342 ntohl(hdr->num), (unsigned char) n);
341 GNUNET_SCHEDULER_cancel (die_task); 343 if (GNUNET_SCHEDULER_NO_TASK != die_task)
344 GNUNET_SCHEDULER_cancel (die_task);
342 die_task = GNUNET_SCHEDULER_add_now (&end_badly, NULL); 345 die_task = GNUNET_SCHEDULER_add_now (&end_badly, NULL);
343 return; 346 return;
344 } 347 }
@@ -356,7 +359,8 @@ notify_receive (void *cls,
356 if (0 == (n % (5000))) 359 if (0 == (n % (5000)))
357 { 360 {
358 fprintf (stderr, "."); 361 fprintf (stderr, ".");
359 GNUNET_SCHEDULER_cancel (die_task); 362 if (GNUNET_SCHEDULER_NO_TASK != die_task)
363 GNUNET_SCHEDULER_cancel (die_task);
360 die_task = GNUNET_SCHEDULER_add_delayed (TIMEOUT, 364 die_task = GNUNET_SCHEDULER_add_delayed (TIMEOUT,
361 &end_badly, 365 &end_badly,
362 NULL); 366 NULL);
@@ -425,7 +429,8 @@ notify_ready (void *cls, size_t size, void *buf)
425 else 429 else
426 { 430 {
427 GNUNET_log(GNUNET_ERROR_TYPE_DEBUG, "All messages scheduled to be sent!!\n"); 431 GNUNET_log(GNUNET_ERROR_TYPE_DEBUG, "All messages scheduled to be sent!!\n");
428 GNUNET_SCHEDULER_cancel(die_task); 432 if (GNUNET_SCHEDULER_NO_TASK != die_task)
433 GNUNET_SCHEDULER_cancel(die_task);
429 die_task = GNUNET_SCHEDULER_add_delayed (UNRELIABLE_TIMEOUT, &end_unreliably, NULL); 434 die_task = GNUNET_SCHEDULER_add_delayed (UNRELIABLE_TIMEOUT, &end_unreliably, NULL);
430 } 435 }
431 if (n % 5000 == 0) 436 if (n % 5000 == 0)
@@ -519,8 +524,10 @@ notify_connect (void *cls,
519 } 524 }
520 if (2 == connected) 525 if (2 == connected)
521 { 526 {
522 GNUNET_SCHEDULER_cancel (die_task); 527 if (GNUNET_SCHEDULER_NO_TASK != die_task)
523 GNUNET_SCHEDULER_cancel (tct); 528 GNUNET_SCHEDULER_cancel (die_task);
529 if (GNUNET_SCHEDULER_NO_TASK != die_task)
530 GNUNET_SCHEDULER_cancel (tct);
524 tct = GNUNET_SCHEDULER_NO_TASK; 531 tct = GNUNET_SCHEDULER_NO_TASK;
525 GNUNET_TRANSPORT_get_hello_cancel (p2.th, &exchange_hello_last, &p2); 532 GNUNET_TRANSPORT_get_hello_cancel (p2.th, &exchange_hello_last, &p2);
526 GNUNET_TRANSPORT_get_hello_cancel (p1.th, &exchange_hello, &p1); 533 GNUNET_TRANSPORT_get_hello_cancel (p1.th, &exchange_hello, &p1);