diff options
author | t3sserakt <t3ss@posteo.de> | 2020-09-08 13:33:25 +0200 |
---|---|---|
committer | t3sserakt <t3ss@posteo.de> | 2020-09-08 13:33:25 +0200 |
commit | 9e012a7a5c3991d224018b2d390b09d8e32c57ae (patch) | |
tree | d0dafee8f74b2ee71b61782642e96dad76edbf99 /src/util | |
parent | 2c797708b38729effe82328484d67a2be02412ed (diff) | |
download | gnunet-9e012a7a5c3991d224018b2d390b09d8e32c57ae.tar.gz gnunet-9e012a7a5c3991d224018b2d390b09d8e32c57ae.zip |
- fixed socket clean up; added sync between start of service and communicator
Diffstat (limited to 'src/util')
-rw-r--r-- | src/util/mq.c | 6 |
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, | |||
273 | break; | 273 | break; |
274 | } | 274 | } |
275 | } | 275 | } |
276 | done: | 276 | done: |
277 | if (GNUNET_NO == handled) | 277 | if (GNUNET_NO == handled) |
278 | { | 278 | { |
279 | LOG (GNUNET_ERROR_TYPE_INFO, | 279 | LOG (GNUNET_ERROR_TYPE_INFO, |
@@ -355,6 +355,10 @@ void | |||
355 | GNUNET_MQ_send (struct GNUNET_MQ_Handle *mq, | 355 | GNUNET_MQ_send (struct GNUNET_MQ_Handle *mq, |
356 | struct GNUNET_MQ_Envelope *ev) | 356 | struct GNUNET_MQ_Envelope *ev) |
357 | { | 357 | { |
358 | if (NULL == mq) | ||
359 | GNUNET_log (GNUNET_ERROR_TYPE_ERROR, | ||
360 | "mq is NUll when sending message of type %u\n", | ||
361 | (unsigned int) ntohs (ev->mh->type)); | ||
358 | GNUNET_assert (NULL != mq); | 362 | GNUNET_assert (NULL != mq); |
359 | GNUNET_assert (NULL == ev->parent_queue); | 363 | GNUNET_assert (NULL == ev->parent_queue); |
360 | 364 | ||