aboutsummaryrefslogtreecommitdiff
path: root/src/util/mq.c
diff options
context:
space:
mode:
authorChristian Grothoff <christian@grothoff.org>2017-02-23 14:28:42 +0100
committerChristian Grothoff <christian@grothoff.org>2017-02-23 14:28:42 +0100
commit6f8ad5f4421b88d22cdb67e0188de132a0031cbc (patch)
tree1f284fe64a30dd59d3bd80b373afff89fb7d8342 /src/util/mq.c
parent450f962ef7349f2f08fbda705e92acb87884af71 (diff)
downloadgnunet-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.c3
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) ||