aboutsummaryrefslogtreecommitdiff
path: root/src/fragmentation/defragmentation.c
diff options
context:
space:
mode:
Diffstat (limited to 'src/fragmentation/defragmentation.c')
-rw-r--r--src/fragmentation/defragmentation.c8
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! */