From c9a693fc4221ddcec8c0582174ad87488ea64650 Mon Sep 17 00:00:00 2001 From: David Barksdale Date: Wed, 10 Jan 2018 13:15:12 -0600 Subject: Try to keep the fs->core MQ from growing too large --- src/fs/gnunet-service-fs_cp.c | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) (limited to 'src/fs') diff --git a/src/fs/gnunet-service-fs_cp.c b/src/fs/gnunet-service-fs_cp.c index 817aed257..6e28ca606 100644 --- a/src/fs/gnunet-service-fs_cp.c +++ b/src/fs/gnunet-service-fs_cp.c @@ -1230,7 +1230,9 @@ handle_p2p_get (void *cls, GNUNET_NO); return; } - if (cp->ppd.pending_replies + cp->delay_queue_size > MAX_QUEUE_PER_PEER) + unsigned int queue_size = GNUNET_MQ_get_length (cp->mq); + queue_size += cp->ppd.pending_replies + cp->delay_queue_size; + if (queue_size > MAX_QUEUE_PER_PEER) { GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Peer `%s' has too many replies queued already. Dropping query.\n", -- cgit v1.2.3