summaryrefslogtreecommitdiff
path: root/src/fs
diff options
context:
space:
mode:
authorDavid Barksdale <amatus@amat.us>2018-01-10 13:15:12 -0600
committerDavid Barksdale <amatus@amat.us>2018-01-10 13:15:12 -0600
commitc9a693fc4221ddcec8c0582174ad87488ea64650 (patch)
tree1a4435e1e573fa7d4f05089edc8697163bec9884 /src/fs
parentc66e64df31713e5e97297300ec8b39536da1369b (diff)
Try to keep the fs->core MQ from growing too large
Diffstat (limited to 'src/fs')
-rw-r--r--src/fs/gnunet-service-fs_cp.c4
1 files changed, 3 insertions, 1 deletions
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",