diff options
| author | Christian Grothoff <christian@grothoff.org> | 2022-01-15 19:54:11 +0100 |
|---|---|---|
| committer | Christian Grothoff <christian@grothoff.org> | 2022-02-19 12:41:00 +0100 |
| commit | 4c3b6b2197ba4fb8d9d696c2a8ca9a170ad12529 (patch) | |
| tree | 648e6a2fe99780f425b2ea3badb53815411afdb2 /src/dhtu | |
| parent | 0f9ccaea08c1d0e0a90725438818a710de1f3f43 (diff) | |
| download | gnunet-4c3b6b2197ba4fb8d9d696c2a8ca9a170ad12529.tar.gz gnunet-4c3b6b2197ba4fb8d9d696c2a8ca9a170ad12529.zip | |
-DHT now takes care of queue size limit
Diffstat (limited to 'src/dhtu')
| -rw-r--r-- | src/dhtu/plugin_dhtu_gnunet.c | 11 |
1 files changed, 0 insertions, 11 deletions
diff --git a/src/dhtu/plugin_dhtu_gnunet.c b/src/dhtu/plugin_dhtu_gnunet.c index 5cf47a850..14e16470c 100644 --- a/src/dhtu/plugin_dhtu_gnunet.c +++ b/src/dhtu/plugin_dhtu_gnunet.c | |||
| @@ -349,17 +349,6 @@ ip_send (void *cls, | |||
| 349 | struct GNUNET_MQ_Envelope *env; | 349 | struct GNUNET_MQ_Envelope *env; |
| 350 | struct GNUNET_MessageHeader *cmsg; | 350 | struct GNUNET_MessageHeader *cmsg; |
| 351 | 351 | ||
| 352 | if (GNUNET_MQ_get_length (target->mq) >= MAXIMUM_PENDING_PER_PEER) | ||
| 353 | { | ||
| 354 | /* skip */ | ||
| 355 | #if FIXME_STATS | ||
| 356 | GNUNET_STATISTICS_update (GDS_stats, | ||
| 357 | "# P2P messages dropped due to full queue", | ||
| 358 | 1, | ||
| 359 | GNUNET_NO); | ||
| 360 | #endif | ||
| 361 | return; | ||
| 362 | } | ||
| 363 | env = GNUNET_MQ_msg_extra (cmsg, | 352 | env = GNUNET_MQ_msg_extra (cmsg, |
| 364 | msg_size, | 353 | msg_size, |
| 365 | GNUNET_MESSAGE_TYPE_DHT_CORE); | 354 | GNUNET_MESSAGE_TYPE_DHT_CORE); |