diff options
author | Christian Grothoff <christian@grothoff.org> | 2019-02-26 11:52:00 +0100 |
---|---|---|
committer | Christian Grothoff <christian@grothoff.org> | 2019-02-26 11:52:20 +0100 |
commit | ec2d7fe4eb37440a3e9539341d41a283feda8798 (patch) | |
tree | f6a680d34b6a6c3c25e9cb1c7c8216e8cbc0cccf /src/util | |
parent | f3a9ff622b9351604f7d9fa35a01bade8cfa7eef (diff) | |
download | gnunet-ec2d7fe4eb37440a3e9539341d41a283feda8798.tar.gz gnunet-ec2d7fe4eb37440a3e9539341d41a283feda8798.zip |
create more specific FC warning
Diffstat (limited to 'src/util')
-rw-r--r-- | src/util/mq.c | 11 |
1 files changed, 9 insertions, 2 deletions
diff --git a/src/util/mq.c b/src/util/mq.c index 72ab8b72d..513c008ee 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-2017 GNUnet e.V. | 3 | Copyright (C) 2012-2019 GNUnet e.V. |
4 | 4 | ||
5 | GNUnet is free software: you can redistribute it and/or modify it | 5 | GNUnet is free software: you can redistribute it and/or modify it |
6 | under the terms of the GNU Affero General Public License as published | 6 | under the terms of the GNU Affero General Public License as published |
@@ -374,7 +374,14 @@ GNUNET_MQ_send (struct GNUNET_MQ_Handle *mq, | |||
374 | GNUNET_assert (NULL == ev->parent_queue); | 374 | GNUNET_assert (NULL == ev->parent_queue); |
375 | 375 | ||
376 | mq->queue_length++; | 376 | mq->queue_length++; |
377 | GNUNET_break (mq->queue_length < 10000); /* This would seem like a bug... */ | 377 | if (mq->queue_length >= 10000) |
378 | { | ||
379 | /* This would seem like a bug... */ | ||
380 | GNUNET_log (GNUNET_ERROR_TYPE_ERROR, | ||
381 | "MQ with %u entries extended by message of type %u (FC broken?)\n", | ||
382 | (unsigned int) mq->queue_length, | ||
383 | (unsigned int) ntohs (ev->mh->type)); | ||
384 | } | ||
378 | ev->parent_queue = mq; | 385 | ev->parent_queue = mq; |
379 | /* is the implementation busy? queue it! */ | 386 | /* is the implementation busy? queue it! */ |
380 | if ( (NULL != mq->current_envelope) || | 387 | if ( (NULL != mq->current_envelope) || |