aboutsummaryrefslogtreecommitdiff
path: root/src/util/mq.c
diff options
context:
space:
mode:
authorChristian Grothoff <christian@grothoff.org>2018-03-03 21:23:50 +0100
committerChristian Grothoff <christian@grothoff.org>2018-03-03 21:23:50 +0100
commit908626e8e19695aa5cd291e5033761ed744d5332 (patch)
tree5ad7fc7d9514968a3e77a799e335c8cb6784ae7e /src/util/mq.c
parentc36f464031c4bebf11ce109cf6edbada584981d3 (diff)
downloadgnunet-908626e8e19695aa5cd291e5033761ed744d5332.tar.gz
gnunet-908626e8e19695aa5cd291e5033761ed744d5332.zip
fix logging
Diffstat (limited to 'src/util/mq.c')
-rw-r--r--src/util/mq.c32
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,