aboutsummaryrefslogtreecommitdiff
path: root/src/mesh
diff options
context:
space:
mode:
Diffstat (limited to 'src/mesh')
-rw-r--r--src/mesh/gnunet-service-mesh.c6
1 files changed, 4 insertions, 2 deletions
diff --git a/src/mesh/gnunet-service-mesh.c b/src/mesh/gnunet-service-mesh.c
index f301a9a4d..34e4a3681 100644
--- a/src/mesh/gnunet-service-mesh.c
+++ b/src/mesh/gnunet-service-mesh.c
@@ -4818,8 +4818,10 @@ queue_add (void *cls, uint16_t type, size_t size,
4818 i = (cinfo->send_buffer_start + cinfo->send_buffer_n) % t->fwd_queue_max; 4818 i = (cinfo->send_buffer_start + cinfo->send_buffer_n) % t->fwd_queue_max;
4819 if (NULL != cinfo->send_buffer[i]) 4819 if (NULL != cinfo->send_buffer[i])
4820 { 4820 {
4821 queue_destroy(cinfo->send_buffer[i], GNUNET_YES); 4821 GNUNET_break (cinfo->send_buffer_n == t->fwd_queue_max); // aka i == start
4822 GNUNET_break (cinfo->send_buffer_n > 0); 4822 queue_destroy(cinfo->send_buffer[cinfo->send_buffer_start], GNUNET_YES);
4823 cinfo->send_buffer_start++;
4824 cinfo->send_buffer_start %= t->fwd_queue_max;
4823 cinfo->send_buffer_n--; 4825 cinfo->send_buffer_n--;
4824 } 4826 }
4825 cinfo->send_buffer[i] = queue; 4827 cinfo->send_buffer[i] = queue;