diff options
author | Christian Grothoff <christian@grothoff.org> | 2018-03-03 21:23:50 +0100 |
---|---|---|
committer | Christian Grothoff <christian@grothoff.org> | 2018-03-03 21:23:50 +0100 |
commit | 908626e8e19695aa5cd291e5033761ed744d5332 (patch) | |
tree | 5ad7fc7d9514968a3e77a799e335c8cb6784ae7e /src/util/mq.c | |
parent | c36f464031c4bebf11ce109cf6edbada584981d3 (diff) | |
download | gnunet-908626e8e19695aa5cd291e5033761ed744d5332.tar.gz gnunet-908626e8e19695aa5cd291e5033761ed744d5332.zip |
fix logging
Diffstat (limited to 'src/util/mq.c')
-rw-r--r-- | src/util/mq.c | 32 |
1 files changed, 16 insertions, 16 deletions
diff --git a/src/util/mq.c b/src/util/mq.c index 33bbaa6ad..af700836c 100644 --- a/src/util/mq.c +++ b/src/util/mq.c | |||
@@ -358,10 +358,10 @@ GNUNET_MQ_send (struct GNUNET_MQ_Handle *mq, | |||
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 | 360 | ||
361 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, | 361 | LOG (GNUNET_ERROR_TYPE_DEBUG, |
362 | "mq: sending message of type %u, queue empty (MQ: %p)\n", | 362 | "sending message of type %u, queue empty (MQ: %p)\n", |
363 | ntohs(ev->mh->type), | 363 | ntohs(ev->mh->type), |
364 | mq); | 364 | mq); |
365 | 365 | ||
366 | mq->send_impl (mq, | 366 | mq->send_impl (mq, |
367 | ev->mh, | 367 | ev->mh, |
@@ -459,9 +459,9 @@ impl_send_continue (void *cls) | |||
459 | mq->envelope_tail, | 459 | mq->envelope_tail, |
460 | mq->current_envelope); | 460 | mq->current_envelope); |
461 | 461 | ||
462 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, | 462 | LOG (GNUNET_ERROR_TYPE_DEBUG, |
463 | "mq: sending message of type %u from queue\n", | 463 | "sending message of type %u from queue\n", |
464 | ntohs(mq->current_envelope->mh->type)); | 464 | ntohs(mq->current_envelope->mh->type)); |
465 | 465 | ||
466 | mq->send_impl (mq, | 466 | mq->send_impl (mq, |
467 | mq->current_envelope->mh, | 467 | mq->current_envelope->mh, |
@@ -851,9 +851,9 @@ GNUNET_MQ_destroy (struct GNUNET_MQ_Handle *mq) | |||
851 | ev); | 851 | ev); |
852 | GNUNET_assert (0 < mq->queue_length); | 852 | GNUNET_assert (0 < mq->queue_length); |
853 | mq->queue_length--; | 853 | mq->queue_length--; |
854 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, | 854 | LOG (GNUNET_ERROR_TYPE_DEBUG, |
855 | "MQ destroy drops message of type %u\n", | 855 | "MQ destroy drops message of type %u\n", |
856 | ntohs (ev->mh->type)); | 856 | ntohs (ev->mh->type)); |
857 | GNUNET_MQ_discard (ev); | 857 | GNUNET_MQ_discard (ev); |
858 | } | 858 | } |
859 | if (NULL != mq->current_envelope) | 859 | if (NULL != mq->current_envelope) |
@@ -861,9 +861,9 @@ GNUNET_MQ_destroy (struct GNUNET_MQ_Handle *mq) | |||
861 | /* we can only discard envelopes that | 861 | /* we can only discard envelopes that |
862 | * are not queued! */ | 862 | * are not queued! */ |
863 | mq->current_envelope->parent_queue = NULL; | 863 | mq->current_envelope->parent_queue = NULL; |
864 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, | 864 | LOG (GNUNET_ERROR_TYPE_DEBUG, |
865 | "MQ destroy drops current message of type %u\n", | 865 | "MQ destroy drops current message of type %u\n", |
866 | ntohs (mq->current_envelope->mh->type)); | 866 | ntohs (mq->current_envelope->mh->type)); |
867 | GNUNET_MQ_discard (mq->current_envelope); | 867 | GNUNET_MQ_discard (mq->current_envelope); |
868 | mq->current_envelope = NULL; | 868 | mq->current_envelope = NULL; |
869 | GNUNET_assert (0 < mq->queue_length); | 869 | GNUNET_assert (0 < mq->queue_length); |
@@ -946,9 +946,9 @@ GNUNET_MQ_send_cancel (struct GNUNET_MQ_Envelope *ev) | |||
946 | mq->envelope_tail, | 946 | mq->envelope_tail, |
947 | mq->current_envelope); | 947 | mq->current_envelope); |
948 | 948 | ||
949 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, | 949 | LOG (GNUNET_ERROR_TYPE_DEBUG, |
950 | "mq: sending canceled message of type %u queue\n", | 950 | "sending canceled message of type %u queue\n", |
951 | ntohs(ev->mh->type)); | 951 | ntohs(ev->mh->type)); |
952 | 952 | ||
953 | mq->send_impl (mq, | 953 | mq->send_impl (mq, |
954 | mq->current_envelope->mh, | 954 | mq->current_envelope->mh, |