[GNUnet-SVN] r17166 - gnunet/src/dht

[gnunet]

Author: grothoff
Date: 2011-10-04 13:51:34 +0200 (Tue, 04 Oct 2011)
New Revision: 17166

Modified:
   gnunet/src/dht/gnunet-service-dht_neighbours.c
Log:
add a few assertions

Modified: gnunet/src/dht/gnunet-service-dht_neighbours.c
===================================================================
--- gnunet/src/dht/gnunet-service-dht_neighbours.c      2011-10-04 11:43:16 UTC 
(rev 17165)
+++ gnunet/src/dht/gnunet-service-dht_neighbours.c      2011-10-04 11:51:34 UTC 
(rev 17166)
@@ -801,7 +801,8 @@
                                           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 @@
     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 @@
                                         &peer->id,
                                         ntohs (pending->msg->size),
                                         &core_transmit_notify, peer);
+  GNUNET_break (NULL != peer->th);
 }