From: Christian Grothoff <christian@grothoff.org>
Date: Tue, 4 Oct 2011 11:51:34 +0000 (+0000)
Subject: add a few assertions
X-Git-Tag: initial-import-from-subversion-38251~16825
X-Git-Url: https://git.librecmc.org/?a=commitdiff_plain;h=cf7f5bd6c15ac3641e65eb3636ef81f527ca8e2e;p=oweals%2Fgnunet.git

add a few assertions
---

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);
 }