summaryrefslogtreecommitdiff
path: root/src/util/mq.c
diff options
context:
space:
mode:
authort3sserakt <t3ss@posteo.de>2020-09-08 13:33:25 +0200
committert3sserakt <t3ss@posteo.de>2020-09-08 13:33:25 +0200
commit9e012a7a5c3991d224018b2d390b09d8e32c57ae (patch)
treed0dafee8f74b2ee71b61782642e96dad76edbf99 /src/util/mq.c
parent2c797708b38729effe82328484d67a2be02412ed (diff)
- fixed socket clean up; added sync between start of service and communicator
Diffstat (limited to 'src/util/mq.c')
-rw-r--r--src/util/mq.c6
1 files changed, 5 insertions, 1 deletions
diff --git a/src/util/mq.c b/src/util/mq.c
index 302b310de..29ead02a4 100644
--- a/src/util/mq.c
+++ b/src/util/mq.c
@@ -273,7 +273,7 @@ GNUNET_MQ_handle_message (const struct GNUNET_MQ_MessageHandler *handlers,
break;
}
}
-done:
+ done:
if (GNUNET_NO == handled)
{
LOG (GNUNET_ERROR_TYPE_INFO,
@@ -355,6 +355,10 @@ void
GNUNET_MQ_send (struct GNUNET_MQ_Handle *mq,
struct GNUNET_MQ_Envelope *ev)
{
+ if (NULL == mq)
+ GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
+ "mq is NUll when sending message of type %u\n",
+ (unsigned int) ntohs (ev->mh->type));
GNUNET_assert (NULL != mq);
GNUNET_assert (NULL == ev->parent_queue);