From bca8edf17fc90862e7267ff22b70a1b7dc94ec96 Mon Sep 17 00:00:00 2001 From: David Barksdale Date: Wed, 10 Jan 2018 21:48:05 -0600 Subject: [PATCH] Try to keep the cadet->code MQ from growing too large --- src/cadet/gnunet-service-cadet_peer.c | 10 +++++++++- 1 file changed, 9 insertions(+), 1 deletion(-) diff --git a/src/cadet/gnunet-service-cadet_peer.c b/src/cadet/gnunet-service-cadet_peer.c index da78a03c4..05555e693 100644 --- a/src/cadet/gnunet-service-cadet_peer.c +++ b/src/cadet/gnunet-service-cadet_peer.c @@ -59,7 +59,10 @@ */ #define IDLE_PATH_TIMEOUT GNUNET_TIME_relative_multiply(GNUNET_TIME_UNIT_MINUTES, 2) - +/** + * Queue size when we start dropping OOO messages. + */ +#define MAX_OOO_QUEUE_SIZE 100 /** @@ -1464,6 +1467,11 @@ GCP_send_ooo (struct CadetPeer *cp, GNUNET_MQ_discard (env); return; } + if (GNUNET_MQ_get_length (cp->core_mq) > MAX_OOO_QUEUE_SIZE) + { + GNUNET_MQ_discard (env); + return; + } GNUNET_MQ_notify_sent (env, &mqm_send_done, cp); -- 2.25.1