diff options
author | Christian Grothoff <christian@grothoff.org> | 2017-02-23 14:28:42 +0100 |
---|---|---|
committer | Christian Grothoff <christian@grothoff.org> | 2017-02-23 14:28:42 +0100 |
commit | 6f8ad5f4421b88d22cdb67e0188de132a0031cbc (patch) | |
tree | 1f284fe64a30dd59d3bd80b373afff89fb7d8342 /src/util/mq.c | |
parent | 450f962ef7349f2f08fbda705e92acb87884af71 (diff) | |
download | gnunet-6f8ad5f4421b88d22cdb67e0188de132a0031cbc.tar.gz gnunet-6f8ad5f4421b88d22cdb67e0188de132a0031cbc.zip |
complain if MQ gets way too long
Diffstat (limited to 'src/util/mq.c')
-rw-r--r-- | src/util/mq.c | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/src/util/mq.c b/src/util/mq.c index 95bcd71cb..75b58bc71 100644 --- a/src/util/mq.c +++ b/src/util/mq.c | |||
@@ -1,6 +1,6 @@ | |||
1 | /* | 1 | /* |
2 | This file is part of GNUnet. | 2 | This file is part of GNUnet. |
3 | Copyright (C) 2012-2014 GNUnet e.V. | 3 | Copyright (C) 2012-2017 GNUnet e.V. |
4 | 4 | ||
5 | GNUnet is free software; you can redistribute it and/or modify | 5 | GNUnet is free software; you can redistribute it and/or modify |
6 | it under the terms of the GNU General Public License as published | 6 | it under the terms of the GNU General Public License as published |
@@ -358,6 +358,7 @@ GNUNET_MQ_send (struct GNUNET_MQ_Handle *mq, | |||
358 | GNUNET_assert (NULL == ev->parent_queue); | 358 | GNUNET_assert (NULL == ev->parent_queue); |
359 | 359 | ||
360 | mq->queue_length++; | 360 | mq->queue_length++; |
361 | GNUNET_break (mq->queue_length < 10000); /* This would seem like a bug... */ | ||
361 | ev->parent_queue = mq; | 362 | ev->parent_queue = mq; |
362 | /* is the implementation busy? queue it! */ | 363 | /* is the implementation busy? queue it! */ |
363 | if ( (NULL != mq->current_envelope) || | 364 | if ( (NULL != mq->current_envelope) || |