diff options
-rw-r--r-- | src/core/test_core_quota_compliance.c | 12 |
1 files changed, 3 insertions, 9 deletions
diff --git a/src/core/test_core_quota_compliance.c b/src/core/test_core_quota_compliance.c index 65f28bb72..f6403532c 100644 --- a/src/core/test_core_quota_compliance.c +++ b/src/core/test_core_quota_compliance.c | |||
@@ -486,14 +486,9 @@ process_mtype (void *cls, | |||
486 | n++; | 486 | n++; |
487 | if (0 == (n % 10)) | 487 | if (0 == (n % 10)) |
488 | fprintf (stderr, "."); | 488 | fprintf (stderr, "."); |
489 | if (n == TOTAL_MSGS) | 489 | |
490 | { | 490 | |
491 | GNUNET_SCHEDULER_cancel (err_task); | 491 | if (running == GNUNET_YES) |
492 | GNUNET_SCHEDULER_add_now (&terminate_task, NULL); | ||
493 | } | ||
494 | else | ||
495 | { | ||
496 | if (running == GNUNET_YES) | ||
497 | GNUNET_break (NULL != | 492 | GNUNET_break (NULL != |
498 | GNUNET_CORE_notify_transmit_ready (p1.ch, | 493 | GNUNET_CORE_notify_transmit_ready (p1.ch, |
499 | 0, | 494 | 0, |
@@ -501,7 +496,6 @@ process_mtype (void *cls, | |||
501 | &p2.id, | 496 | &p2.id, |
502 | MESSAGESIZE, | 497 | MESSAGESIZE, |
503 | &transmit_ready, &p1)); | 498 | &transmit_ready, &p1)); |
504 | } | ||
505 | return GNUNET_OK; | 499 | return GNUNET_OK; |
506 | } | 500 | } |
507 | 501 | ||