GNUNET_SCHEDULER_TaskCallback sent_cb;
/**
- * Closure for @e sent_cb
+ * Closure for @e send_cb
*/
void *sent_cls;
uint16_t mtype = ntohs (mh->type);
LOG (GNUNET_ERROR_TYPE_DEBUG,
- "Queue %p received message of type %u and size %u\n",
- mq,
- mtype,
- msize);
+ "Received message of type %u and size %u\n",
+ mtype, msize);
if (NULL == mq->handlers)
goto done;
}
GNUNET_assert (NULL == mq->envelope_head);
mq->current_envelope = ev;
-
- GNUNET_log (GNUNET_ERROR_TYPE_WARNING,
- "mq: sending message of type %u, queue empty\n",
- ntohs(ev->mh->type));
-
mq->send_impl (mq,
ev->mh,
mq->impl_state);
GNUNET_CONTAINER_DLL_remove (mq->envelope_head,
mq->envelope_tail,
mq->current_envelope);
-
- GNUNET_log (GNUNET_ERROR_TYPE_WARNING,
- "mq: sending message of type %u from queue\n", ntohs(mq->current_envelope->mh->type));
-
mq->send_impl (mq,
mq->current_envelope->mh,
mq->impl_state);
GNUNET_CONTAINER_DLL_remove (mq->envelope_head,
mq->envelope_tail,
mq->current_envelope);
-
- GNUNET_log (GNUNET_ERROR_TYPE_WARNING,
- "mq: sending canceled message of type %u queue\n", ntohs(ev->mh->type));
-
mq->send_impl (mq,
mq->current_envelope->mh,
mq->impl_state);