gnunet-svn
[Top][All Lists]
Advanced

[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]

[GNUnet-SVN] r14248 - gnunet/src/fs


From: gnunet
Subject: [GNUnet-SVN] r14248 - gnunet/src/fs
Date: Mon, 24 Jan 2011 22:28:21 +0100

Author: grothoff
Date: 2011-01-24 22:28:21 +0100 (Mon, 24 Jan 2011)
New Revision: 14248

Modified:
   gnunet/src/fs/gnunet-service-fs.c
Log:
asserts

Modified: gnunet/src/fs/gnunet-service-fs.c
===================================================================
--- gnunet/src/fs/gnunet-service-fs.c   2011-01-24 20:53:23 UTC (rev 14247)
+++ gnunet/src/fs/gnunet-service-fs.c   2011-01-24 21:28:21 UTC (rev 14248)
@@ -1478,6 +1478,7 @@
   GNUNET_CONTAINER_DLL_remove (pml->target->pending_messages_head,
                               pml->target->pending_messages_tail,
                               pml->pm);
+  GNUNET_assert (pml->target->pending_requests > 0);
   pml->target->pending_requests--;
   GNUNET_free (pml->pm);
   GNUNET_free (pml);
@@ -2222,6 +2223,7 @@
          GNUNET_CONTAINER_DLL_remove (cp->pending_messages_head,
                                       cp->pending_messages_tail,
                                       pm);
+         GNUNET_assert (cp->pending_requests > 0);
          cp->pending_requests--;    
          destroy_pending_message (pm, 0);
        }
@@ -2260,6 +2262,7 @@
          GNUNET_CONTAINER_DLL_remove (cp->pending_messages_head,
                                       cp->pending_messages_tail,
                                       pm);
+         GNUNET_assert (cp->pending_requests > 0);
          cp->pending_requests--;
        }
       destroy_pending_message (pm, cp->pid);
@@ -2675,6 +2678,11 @@
   uint32_t bm;
   unsigned int i;
 
+#if DEBUG_FS
+      GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
+                 "Core called back... for query `%s'.\n",
+                 GNUNET_h2s (&pr->query));
+#endif
   /* (3) transmit, update ttl/priority */
   cp = GNUNET_CONTAINER_multihashmap_get (connected_peers,
                                          &peer->hashPubKey);
@@ -3144,6 +3152,11 @@
       GNUNET_assert (cp->irc == NULL);
       pr->pirc = cp;
       cp->pr = pr;
+#if DEBUG_FS
+      GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
+                 "Asking core for bandwidth for query `%s'.\n",
+                 GNUNET_h2s (&pr->query));
+#endif
       cp->irc = GNUNET_CORE_peer_change_preference (core,
                                                    &psc.target,
                                                    
GNUNET_CONSTANTS_SERVICE_TIMEOUT, 




reply via email to

[Prev in Thread] Current Thread [Next in Thread]