aboutsummaryrefslogtreecommitdiff
path: root/src/util/mq.c
diff options
context:
space:
mode:
Diffstat (limited to 'src/util/mq.c')
-rw-r--r--src/util/mq.c12
1 files changed, 12 insertions, 0 deletions
diff --git a/src/util/mq.c b/src/util/mq.c
index 90b2aa968..5523b261c 100644
--- a/src/util/mq.c
+++ b/src/util/mq.c
@@ -357,6 +357,10 @@ GNUNET_MQ_send (struct GNUNET_MQ_Handle *mq,
357 } 357 }
358 GNUNET_assert (NULL == mq->envelope_head); 358 GNUNET_assert (NULL == mq->envelope_head);
359 mq->current_envelope = ev; 359 mq->current_envelope = ev;
360
361 GNUNET_log (GNUNET_ERROR_TYPE_WARNING,
362 "mq: sending message of type %u, queue empty\n", ntohs(ev->mh->type));
363
360 mq->send_impl (mq, 364 mq->send_impl (mq,
361 ev->mh, 365 ev->mh,
362 mq->impl_state); 366 mq->impl_state);
@@ -452,6 +456,10 @@ impl_send_continue (void *cls)
452 GNUNET_CONTAINER_DLL_remove (mq->envelope_head, 456 GNUNET_CONTAINER_DLL_remove (mq->envelope_head,
453 mq->envelope_tail, 457 mq->envelope_tail,
454 mq->current_envelope); 458 mq->current_envelope);
459
460 GNUNET_log (GNUNET_ERROR_TYPE_WARNING,
461 "mq: sending message of type %u from queue\n", ntohs(mq->current_envelope->mh->type));
462
455 mq->send_impl (mq, 463 mq->send_impl (mq,
456 mq->current_envelope->mh, 464 mq->current_envelope->mh,
457 mq->impl_state); 465 mq->impl_state);
@@ -928,6 +936,10 @@ GNUNET_MQ_send_cancel (struct GNUNET_MQ_Envelope *ev)
928 GNUNET_CONTAINER_DLL_remove (mq->envelope_head, 936 GNUNET_CONTAINER_DLL_remove (mq->envelope_head,
929 mq->envelope_tail, 937 mq->envelope_tail,
930 mq->current_envelope); 938 mq->current_envelope);
939
940 GNUNET_log (GNUNET_ERROR_TYPE_WARNING,
941 "mq: sending canceled message of type %u queue\n", ntohs(ev->mh->type));
942
931 mq->send_impl (mq, 943 mq->send_impl (mq,
932 mq->current_envelope->mh, 944 mq->current_envelope->mh,
933 mq->impl_state); 945 mq->impl_state);