From b79845ad3e78eb26477c77dda6a0ffaca415cdf9 Mon Sep 17 00:00:00 2001 From: "onledger.net" <42262747+rippleitinnz@users.noreply.github.com> Date: Sun, 15 Jun 2025 11:13:53 +1200 Subject: [PATCH] Increase MAX_IN_MSG_QUEUE Increase MAX_IN_MSG_QUEUE to 12bits binary (4095) to handle larger UNL of 64 messaging --- src/comm/comm_session.cpp | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/src/comm/comm_session.cpp b/src/comm/comm_session.cpp index cd6738b4..9fd8d2bf 100644 --- a/src/comm/comm_session.cpp +++ b/src/comm/comm_session.cpp @@ -10,7 +10,7 @@ namespace comm { constexpr uint32_t INTERVALMS = 60000; constexpr uint32_t UNVERIFIED_INACTIVE_TIMEOUT = 5000; // Time threshold ms for unverified inactive connections. - constexpr uint16_t MAX_IN_MSG_QUEUE_SIZE = 255; // Maximum in message queue size, The size passed is rounded to next number in binary sequence 1(1),11(3),111(7),1111(15),11111(31).... + constexpr uint16_t MAX_IN_MSG_QUEUE_SIZE = 4095; // Maximum in message queue size, The size passed is rounded to next number in binary sequence 1(1),11(3),111(7),1111(15),11111(31).... comm_session::comm_session(corebill::tracker &violation_tracker, std::string_view host_address, hpws::client &&hpws_client, const bool is_ipv4, const bool is_inbound, const uint64_t (&metric_thresholds)[5], const bool corebill_enabled) @@ -409,4 +409,4 @@ namespace comm { } -} // namespace comm \ No newline at end of file +} // namespace comm