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