const struct GNUNET_MessageHeader *msg = GNUNET_MQ_impl_current (mq);
uint16_t msize;
+ GNUNET_log_from (GNUNET_ERROR_TYPE_DEBUG, "mesh-mq",
+ "writing message (t: %s, s: %s) to buffer\n",
+ ntohs (msg->type), ntohs (msg->size));
+
state->th = NULL;
if (NULL == buf)
{
GNUNET_assert (NULL == state->th);
GNUNET_MQ_impl_send_commit (mq);
+ GNUNET_log_from (GNUNET_ERROR_TYPE_DEBUG, "mesh-mq",
+ "calling ntr for message (t: %s, s: %s)\n",
+ ntohs (msg->type), ntohs (msg->size));
state->th =
GNUNET_MESH_notify_transmit_ready (state->tunnel,
/* FIXME: add option for corking */
if (NULL == mq->assoc_map)
return NULL;
val = GNUNET_CONTAINER_multihashmap32_get (mq->assoc_map, request_id);
- GNUNET_assert (NULL != val);
- GNUNET_assert (GNUNET_YES ==
- GNUNET_CONTAINER_multihashmap32_remove (mq->assoc_map, request_id, val));
+ GNUNET_CONTAINER_multihashmap32_remove_all (mq->assoc_map, request_id);
return val;
}