diff options
Diffstat (limited to 'src/dht/gnunet-service-xdht_neighbours.c')
-rw-r--r-- | src/dht/gnunet-service-xdht_neighbours.c | 16 |
1 files changed, 12 insertions, 4 deletions
diff --git a/src/dht/gnunet-service-xdht_neighbours.c b/src/dht/gnunet-service-xdht_neighbours.c index 50fed309b..3ad86e941 100644 --- a/src/dht/gnunet-service-xdht_neighbours.c +++ b/src/dht/gnunet-service-xdht_neighbours.c | |||
@@ -979,11 +979,18 @@ core_transmit_notify (void *cls, size_t size, void *buf) | |||
979 | size_t msize; | 979 | size_t msize; |
980 | 980 | ||
981 | peer->th = NULL; | 981 | peer->th = NULL; |
982 | while ((NULL != (pending = peer->head)) && | 982 | while ( (NULL != (pending = peer->head)) && |
983 | (0 == GNUNET_TIME_absolute_get_remaining (pending->timeout).rel_value_us)) | 983 | (0 == GNUNET_TIME_absolute_get_remaining (pending->timeout).rel_value_us) ) |
984 | { | 984 | { |
985 | GNUNET_STATISTICS_update (GDS_stats, | ||
986 | gettext_noop | ||
987 | ("# Messages dropped (CORE timeout)"), | ||
988 | 1, | ||
989 | GNUNET_NO); | ||
985 | peer->pending_count--; | 990 | peer->pending_count--; |
986 | GNUNET_CONTAINER_DLL_remove (peer->head, peer->tail, pending); | 991 | GNUNET_CONTAINER_DLL_remove (peer->head, |
992 | peer->tail, | ||
993 | pending); | ||
987 | GNUNET_free (pending); | 994 | GNUNET_free (pending); |
988 | } | 995 | } |
989 | if (NULL == pending) | 996 | if (NULL == pending) |
@@ -1009,7 +1016,8 @@ core_transmit_notify (void *cls, size_t size, void *buf) | |||
1009 | { | 1016 | { |
1010 | GNUNET_STATISTICS_update (GDS_stats, | 1017 | GNUNET_STATISTICS_update (GDS_stats, |
1011 | gettext_noop | 1018 | gettext_noop |
1012 | ("# Bytes transmitted to other peers"), msize, | 1019 | ("# Bytes transmitted to other peers"), |
1020 | msize, | ||
1013 | GNUNET_NO); | 1021 | GNUNET_NO); |
1014 | memcpy (&cbuf[off], pending->msg, msize); | 1022 | memcpy (&cbuf[off], pending->msg, msize); |
1015 | off += msize; | 1023 | off += msize; |