From cf7f5bd6c15ac3641e65eb3636ef81f527ca8e2e Mon Sep 17 00:00:00 2001 From: Christian Grothoff Date: Tue, 4 Oct 2011 11:51:34 +0000 Subject: [PATCH] add a few assertions --- src/dht/gnunet-service-dht_neighbours.c | 21 ++++++++++++--------- 1 file changed, 12 insertions(+), 9 deletions(-) diff --git a/src/dht/gnunet-service-dht_neighbours.c b/src/dht/gnunet-service-dht_neighbours.c index a750d3590..6a3b74ea9 100644 --- a/src/dht/gnunet-service-dht_neighbours.c +++ b/src/dht/gnunet-service-dht_neighbours.c @@ -801,7 +801,8 @@ core_transmit_notify (void *cls, size_t size, void *buf) pending->importance, GNUNET_TIME_absolute_get_remaining (pending->timeout), &peer->id, ntohs (pending->msg->size), - &core_transmit_notify, peer); + &core_transmit_notify, peer); + GNUNET_break (NULL != peer->th); return 0; } off = 0; @@ -818,14 +819,15 @@ core_transmit_notify (void *cls, size_t size, void *buf) GNUNET_free (pending); } if (peer->head != NULL) - { - peer->th - = GNUNET_CORE_notify_transmit_ready (coreAPI, GNUNET_YES, - pending->importance, - GNUNET_TIME_absolute_get_remaining (pending->timeout), - &peer->id, msize, - &core_transmit_notify, peer); - } + { + peer->th + = GNUNET_CORE_notify_transmit_ready (coreAPI, GNUNET_YES, + pending->importance, + GNUNET_TIME_absolute_get_remaining (pending->timeout), + &peer->id, msize, + &core_transmit_notify, peer); + GNUNET_break (NULL != peer->th); + } return off; } @@ -855,6 +857,7 @@ process_peer_queue (struct PeerInfo *peer) &peer->id, ntohs (pending->msg->size), &core_transmit_notify, peer); + GNUNET_break (NULL != peer->th); } -- 2.25.1