diff options
-rw-r--r-- | src/mesh/gnunet-service-mesh.c | 11 |
1 files changed, 10 insertions, 1 deletions
diff --git a/src/mesh/gnunet-service-mesh.c b/src/mesh/gnunet-service-mesh.c index 44610d60e..8e00337b5 100644 --- a/src/mesh/gnunet-service-mesh.c +++ b/src/mesh/gnunet-service-mesh.c | |||
@@ -3089,6 +3089,7 @@ tunnel_destroy_child (void *cls, | |||
3089 | queue_destroy(cinfo->send_buffer[i], GNUNET_YES); | 3089 | queue_destroy(cinfo->send_buffer[i], GNUNET_YES); |
3090 | else | 3090 | else |
3091 | GNUNET_break (0); | 3091 | GNUNET_break (0); |
3092 | GNUNET_log (GNUNET_ERROR_TYPE_INFO, "%u %u\n", c, cinfo->send_buffer_n); | ||
3092 | } | 3093 | } |
3093 | GNUNET_free_non_null (cinfo->send_buffer); | 3094 | GNUNET_free_non_null (cinfo->send_buffer); |
3094 | GNUNET_free (cinfo); | 3095 | GNUNET_free (cinfo); |
@@ -4727,7 +4728,15 @@ queue_send (void *cls, size_t size, void *buf) | |||
4727 | } | 4728 | } |
4728 | 4729 | ||
4729 | cinfo = tunnel_get_neighbor_fc(t, &dst_id); | 4730 | cinfo = tunnel_get_neighbor_fc(t, &dst_id); |
4730 | GNUNET_break(cinfo->send_buffer[cinfo->send_buffer_start] == queue); | 4731 | if (cinfo->send_buffer[cinfo->send_buffer_start] != queue) |
4732 | { | ||
4733 | GNUNET_break(0); | ||
4734 | GNUNET_log (GNUNET_ERROR_TYPE_WARNING, | ||
4735 | "at pos %u (%p) != %p\n", | ||
4736 | cinfo->send_buffer_start, | ||
4737 | cinfo->send_buffer[cinfo->send_buffer_start], | ||
4738 | queue); | ||
4739 | } | ||
4731 | GNUNET_break(cinfo->send_buffer_n > 0); | 4740 | GNUNET_break(cinfo->send_buffer_n > 0); |
4732 | cinfo->send_buffer[cinfo->send_buffer_start] = NULL; | 4741 | cinfo->send_buffer[cinfo->send_buffer_start] = NULL; |
4733 | cinfo->send_buffer_n--; | 4742 | cinfo->send_buffer_n--; |