Skip to content

Commit a8c1922

Browse files
committed
tighten up peer query-process limit
1 parent c444c07 commit a8c1922

1 file changed

Lines changed: 2 additions & 3 deletions

File tree

src/overlay/Peer.cpp

Lines changed: 2 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -132,7 +132,6 @@ populateSignatureCache(AppConnector& app, TransactionFrameBaseConstPtr tx)
132132

133133
static constexpr VirtualClock::time_point PING_NOT_SENT =
134134
VirtualClock::time_point::min();
135-
static constexpr uint32_t QUERY_RESPONSE_MULTIPLIER = 5;
136135

137136
Peer::Peer(Application& app, PeerRole role)
138137
: mAppConnector(app.getAppConnector())
@@ -1426,8 +1425,8 @@ Peer::process(QueryInfo& queryInfo, std::optional<uint32_t> maxQueriesPerWindow)
14261425
std::chrono::duration_cast<std::chrono::seconds>(
14271426
mAppConnector.getLedgerManager().getExpectedLedgerCloseTime() *
14281427
cfg.MAX_SLOTS_TO_REMEMBER);
1429-
uint32_t const QUERIES_PER_WINDOW = maxQueriesPerWindow.value_or(
1430-
QUERY_WINDOW.count() * QUERY_RESPONSE_MULTIPLIER);
1428+
uint32_t const QUERIES_PER_WINDOW =
1429+
maxQueriesPerWindow.value_or(2 * cfg.MAX_SLOTS_TO_REMEMBER + 1);
14311430
if (mAppConnector.now() - queryInfo.mLastTimeStamp >= QUERY_WINDOW)
14321431
{
14331432
queryInfo.mLastTimeStamp = mAppConnector.now();

0 commit comments

Comments
 (0)