diff options
author | t3sserakt <t3ss@posteo.de> | 2017-10-14 02:56:14 +0200 |
---|---|---|
committer | t3sserakt <t3ss@posteo.de> | 2017-10-14 02:56:14 +0200 |
commit | 6490b5f31e58e9ec008f8c5ceda28f6054f1bbba (patch) | |
tree | 7a62a8814f690e578cc7acab0df8fe93415f50c9 /src/util/mq.c | |
parent | 2af1f1b81cefe8307c702f304451ae67c0fa1437 (diff) | |
download | gnunet-6490b5f31e58e9ec008f8c5ceda28f6054f1bbba.tar.gz gnunet-6490b5f31e58e9ec008f8c5ceda28f6054f1bbba.zip |
added mq logging
Diffstat (limited to 'src/util/mq.c')
-rw-r--r-- | src/util/mq.c | 12 |
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); |