diff options
author | Phil <phil.buschmann@tum.de> | 2018-01-11 10:21:52 +0100 |
---|---|---|
committer | Phil <phil.buschmann@tum.de> | 2018-01-11 10:21:52 +0100 |
commit | 60c963315271ce4314b708bef519eb4fb64f0979 (patch) | |
tree | 93e5b2a48279b32568531485eed21229b3c374c5 /src/cadet/gnunet-service-cadet_peer.c | |
parent | afb2171eb752d82918048b393fda6f01f863b49a (diff) | |
parent | bca8edf17fc90862e7267ff22b70a1b7dc94ec96 (diff) | |
download | gnunet-60c963315271ce4314b708bef519eb4fb64f0979.tar.gz gnunet-60c963315271ce4314b708bef519eb4fb64f0979.zip |
Merge remote-tracking branch 'gnunet/master' into identity_oidc
Diffstat (limited to 'src/cadet/gnunet-service-cadet_peer.c')
-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); |