diff options
author | David Barksdale <amatus@amat.us> | 2018-01-10 21:48:05 -0600 |
---|---|---|
committer | David Barksdale <amatus@amat.us> | 2018-01-10 21:48:05 -0600 |
commit | bca8edf17fc90862e7267ff22b70a1b7dc94ec96 (patch) | |
tree | 45f34ee1309f651135efdad08490f29aca243660 /src/cadet | |
parent | 67bb148acd0de26403e4dd89659efeec8889a2c5 (diff) | |
download | gnunet-bca8edf17fc90862e7267ff22b70a1b7dc94ec96.tar.gz gnunet-bca8edf17fc90862e7267ff22b70a1b7dc94ec96.zip |
Try to keep the cadet->code MQ from growing too large
Diffstat (limited to 'src/cadet')
-rw-r--r-- | src/cadet/gnunet-service-cadet_peer.c | 10 |
1 files changed, 9 insertions, 1 deletions
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 @@ | |||
59 | */ | 59 | */ |
60 | #define IDLE_PATH_TIMEOUT GNUNET_TIME_relative_multiply(GNUNET_TIME_UNIT_MINUTES, 2) | 60 | #define IDLE_PATH_TIMEOUT GNUNET_TIME_relative_multiply(GNUNET_TIME_UNIT_MINUTES, 2) |
61 | 61 | ||
62 | 62 | /** | |
63 | * Queue size when we start dropping OOO messages. | ||
64 | */ | ||
65 | #define MAX_OOO_QUEUE_SIZE 100 | ||
63 | 66 | ||
64 | 67 | ||
65 | /** | 68 | /** |
@@ -1464,6 +1467,11 @@ GCP_send_ooo (struct CadetPeer *cp, | |||
1464 | GNUNET_MQ_discard (env); | 1467 | GNUNET_MQ_discard (env); |
1465 | return; | 1468 | return; |
1466 | } | 1469 | } |
1470 | if (GNUNET_MQ_get_length (cp->core_mq) > MAX_OOO_QUEUE_SIZE) | ||
1471 | { | ||
1472 | GNUNET_MQ_discard (env); | ||
1473 | return; | ||
1474 | } | ||
1467 | GNUNET_MQ_notify_sent (env, | 1475 | GNUNET_MQ_notify_sent (env, |
1468 | &mqm_send_done, | 1476 | &mqm_send_done, |
1469 | cp); | 1477 | cp); |