aboutsummaryrefslogtreecommitdiff
path: root/src/fragmentation/fragmentation.c
diff options
context:
space:
mode:
authorChristian Grothoff <christian@grothoff.org>2011-07-27 07:32:32 +0000
committerChristian Grothoff <christian@grothoff.org>2011-07-27 07:32:32 +0000
commit22dafb003418aab11e036230b3761116c397d239 (patch)
tree871f6dd1452fb3223ebbd8680b3e75dcdc879fc8 /src/fragmentation/fragmentation.c
parentfc49f1b524fce53459692ddffe05474876e4969c (diff)
downloadgnunet-22dafb003418aab11e036230b3761116c397d239.tar.gz
gnunet-22dafb003418aab11e036230b3761116c397d239.zip
fix
Diffstat (limited to 'src/fragmentation/fragmentation.c')
-rw-r--r--src/fragmentation/fragmentation.c17
1 files changed, 13 insertions, 4 deletions
diff --git a/src/fragmentation/fragmentation.c b/src/fragmentation/fragmentation.c
index 71a84225c..77b4c2e49 100644
--- a/src/fragmentation/fragmentation.c
+++ b/src/fragmentation/fragmentation.c
@@ -347,10 +347,19 @@ GNUNET_FRAGMENT_process_ack (struct GNUNET_FRAGMENT_Context *fc,
347 if (0 != fc->acks) 347 if (0 != fc->acks)
348 { 348 {
349 /* more to transmit, do so right now (if tracker permits...) */ 349 /* more to transmit, do so right now (if tracker permits...) */
350 GNUNET_assert(fc->task != GNUNET_SCHEDULER_NO_TASK); 350 if (fc->task != GNUNET_SCHEDULER_NO_TASK)
351 GNUNET_SCHEDULER_cancel (fc->task); 351 {
352 fc->task = GNUNET_SCHEDULER_add_now (&transmit_next, 352 /* schedule next transmission now, no point in waiting... */
353 fc); 353 GNUNET_SCHEDULER_cancel (fc->task);
354 fc->task = GNUNET_SCHEDULER_add_now (&transmit_next,
355 fc);
356 }
357 else
358 {
359 /* only case where there is no task should be if we're waiting
360 for the right to transmit again (proc_busy set to YES) */
361 GNUNET_assert (GNUNET_YES == fc->proc_busy);
362 }
354 return GNUNET_NO; 363 return GNUNET_NO;
355 } 364 }
356 365