diff options
Diffstat (limited to 'src/fragmentation/defragmentation.c')
-rw-r--r-- | src/fragmentation/defragmentation.c | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/src/fragmentation/defragmentation.c b/src/fragmentation/defragmentation.c index f42207046..5f9eace13 100644 --- a/src/fragmentation/defragmentation.c +++ b/src/fragmentation/defragmentation.c | |||
@@ -459,7 +459,7 @@ GNUNET_DEFRAGMENT_process_fragment (struct GNUNET_DEFRAGMENT_Context *dc, | |||
459 | for (mc = dc->head; NULL != mc; mc = mc->next) | 459 | for (mc = dc->head; NULL != mc; mc = mc->next) |
460 | if (mc->fragment_id > fid) | 460 | if (mc->fragment_id > fid) |
461 | last++; | 461 | last++; |
462 | 462 | ||
463 | mc = dc->head; | 463 | mc = dc->head; |
464 | while ((NULL != mc) && (fid != mc->fragment_id)) | 464 | while ((NULL != mc) && (fid != mc->fragment_id)) |
465 | mc = mc->next; | 465 | mc = mc->next; |
@@ -538,13 +538,13 @@ GNUNET_DEFRAGMENT_process_fragment (struct GNUNET_DEFRAGMENT_Context *dc, | |||
538 | } | 538 | } |
539 | /* send ACK */ | 539 | /* send ACK */ |
540 | if (mc->frag_times_write_offset - mc->frag_times_start_offset > 1) | 540 | if (mc->frag_times_write_offset - mc->frag_times_start_offset > 1) |
541 | { | 541 | { |
542 | dc->latency = estimate_latency (mc); | 542 | dc->latency = estimate_latency (mc); |
543 | } | 543 | } |
544 | delay = GNUNET_TIME_relative_multiply (dc->latency, bc + 1); | 544 | delay = GNUNET_TIME_relative_multiply (dc->latency, bc + 1); |
545 | if ( (last + fid == num_fragments) || | 545 | if ( (last + fid == num_fragments) || |
546 | (0 == mc->bits) || | 546 | (0 == mc->bits) || |
547 | (GNUNET_YES == duplicate)) | 547 | (GNUNET_YES == duplicate)) |
548 | { | 548 | { |
549 | /* message complete or duplicate or last missing fragment in | 549 | /* message complete or duplicate or last missing fragment in |
550 | linear sequence; ACK now! */ | 550 | linear sequence; ACK now! */ |