diff options
author | Matthias Wachs <wachs@net.in.tum.de> | 2011-06-20 09:05:51 +0000 |
---|---|---|
committer | Matthias Wachs <wachs@net.in.tum.de> | 2011-06-20 09:05:51 +0000 |
commit | 1ad257905ce4a45bbe59b08ea52a3c3c6622da5d (patch) | |
tree | 5ebee625c994338f1fd592cae6c1d75af1909603 /src/transport/test_transport_api_unreliability.c | |
parent | 61a008c4e471cd5081d5c2871949da779246a868 (diff) | |
download | gnunet-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.c | 21 |
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); |