Merge branch 'master' of ssh://gnunet.org/gnunet

[oweals/gnunet.git] / src / util / mq.c

diff --git a/src/util/mq.c b/src/util/mq.c
index a8216d9648a7490af5f7e2ee9128070a759ea98b..79e2d0455969bfcd7bff9a2b2b49e87948ca0772 100644 (file)
--- a/src/util/mq.c
+++ b/src/util/mq.c
@@ -1,6 +1,6 @@
 /*
      This file is part of GNUnet.
-     Copyright (C) 2012-2014 GNUnet e.V.
+     Copyright (C) 2012-2017 GNUnet e.V.
 
      GNUnet is free software; you can redistribute it and/or modify
      it under the terms of the GNU General Public License as published
@@ -362,6 +362,7 @@ GNUNET_MQ_send (struct GNUNET_MQ_Handle *mq,
   GNUNET_assert (NULL == ev->parent_queue);
 
   mq->queue_length++;
+  GNUNET_break (mq->queue_length < 10000); /* This would seem like a bug... */
   ev->parent_queue = mq;
   /* is the implementation busy? queue it! */
   if ( (NULL != mq->current_envelope) ||
@@ -763,7 +764,7 @@ server_client_send_impl (struct GNUNET_MQ_Handle *mq,
   GNUNET_assert (NULL != mq);
 
   LOG (GNUNET_ERROR_TYPE_DEBUG,
-       "Transmitting message of type %u and size %u\n",
+       "Sending message of type %u and size %u\n",
        ntohs (msg->type), ntohs (msg->size));
 
   struct ServerClientSocketState *state = impl_state;