diff --git a/llarp/path/transit_hop.cpp b/llarp/path/transit_hop.cpp index 0dc691c0b..edae826c1 100644 --- a/llarp/path/transit_hop.cpp +++ b/llarp/path/transit_hop.cpp @@ -32,7 +32,7 @@ namespace llarp return stream; } - TransitHop::TransitHop() : m_UpstreamGather(128), m_DownstreamGather(128) + TransitHop::TransitHop() : m_UpstreamGather(512), m_DownstreamGather(512) { m_UpstreamGather.enable(); m_DownstreamGather.enable(); diff --git a/llarp/router/i_outbound_message_handler.hpp b/llarp/router/i_outbound_message_handler.hpp index 9ffa784a7..5f167153a 100644 --- a/llarp/router/i_outbound_message_handler.hpp +++ b/llarp/router/i_outbound_message_handler.hpp @@ -24,9 +24,9 @@ namespace llarp using SendStatusHandler = std::function; - static const size_t MAX_PATH_QUEUE_SIZE = 40; - static const size_t MAX_OUTBOUND_QUEUE_SIZE = 200; - static const size_t MAX_OUTBOUND_MESSAGES_PER_TICK = 20; + static const size_t MAX_PATH_QUEUE_SIZE = 100; + static const size_t MAX_OUTBOUND_QUEUE_SIZE = 1000; + static const size_t MAX_OUTBOUND_MESSAGES_PER_TICK = 500; struct IOutboundMessageHandler {