From c3ad4b5269fa8191cb4e1b13b488bfd4846a88e5 Mon Sep 17 00:00:00 2001 From: Valentin Balaschenko <13349202+vlntb@users.noreply.github.com> Date: Thu, 26 Feb 2026 17:27:10 +0000 Subject: [PATCH] renaming --- src/xrpld/app/main/GRPCServer.cpp | 22 +++++++++++----------- src/xrpld/app/main/GRPCServer.h | 4 ++-- 2 files changed, 13 insertions(+), 13 deletions(-) diff --git a/src/xrpld/app/main/GRPCServer.cpp b/src/xrpld/app/main/GRPCServer.cpp index 18dd4b8862..972fbd138c 100644 --- a/src/xrpld/app/main/GRPCServer.cpp +++ b/src/xrpld/app/main/GRPCServer.cpp @@ -362,7 +362,7 @@ GRPCServerImpl::shutdown() backoffAlarm_.Cancel(); { std::lock_guard lk(backoffMutex_); - pendingReposts_.clear(); + deferredListeners_.clear(); backoffScheduled_ = false; } JLOG(journal_.debug()) << "Backoff alarm cancelled"; @@ -440,7 +440,7 @@ GRPCServerImpl::handleRpcs() // Check FD pressure before creating clone if (FDGuard::should_throttle(0.70)) { - JLOG(journal_.warn()) << "gRPC FD pressure detected - deferring repost"; + JLOG(journal_.warn()) << "gRPC FD pressure detected - deferring listener"; { std::lock_guard lk(backoffMutex_); @@ -451,7 +451,7 @@ GRPCServerImpl::handleRpcs() requests.end(), [ptr](std::shared_ptr& sPtr) { return sPtr.get() == ptr; }); BOOST_ASSERT(it != requests.end()); - pendingReposts_.push_back(*it); + deferredListeners_.push_back(*it); if (!backoffScheduled_) { @@ -498,15 +498,15 @@ GRPCServerImpl::handleRpcs() void GRPCServerImpl::onBackoffFired() { - std::vector> toRepost; + std::vector> deferred; { std::lock_guard lk(backoffMutex_); backoffScheduled_ = false; - toRepost.swap(pendingReposts_); + deferred.swap(deferredListeners_); } - JLOG(journal_.debug()) << "Processing " << toRepost.size() << " deferred reposts"; + JLOG(journal_.debug()) << "Processing " << deferred.size() << " deferred listeners"; if (FDGuard::should_throttle(0.70)) { @@ -514,10 +514,10 @@ GRPCServerImpl::onBackoffFired() std::lock_guard lk(backoffMutex_); - pendingReposts_.insert( - pendingReposts_.end(), - std::make_move_iterator(toRepost.begin()), - std::make_move_iterator(toRepost.end())); + deferredListeners_.insert( + deferredListeners_.end(), + std::make_move_iterator(deferred.begin()), + std::make_move_iterator(deferred.end())); if (!backoffScheduled_) { @@ -539,7 +539,7 @@ GRPCServerImpl::onBackoffFired() JLOG(journal_.info()) << "FD pressure relieved - resuming normal operation"; backoff_.reset(); - for (auto const& ptr : toRepost) + for (auto const& ptr : deferred) { auto cloned = ptr->clone(); requests_.push_back(cloned); diff --git a/src/xrpld/app/main/GRPCServer.h b/src/xrpld/app/main/GRPCServer.h index ece1b8976d..2a702452e4 100644 --- a/src/xrpld/app/main/GRPCServer.h +++ b/src/xrpld/app/main/GRPCServer.h @@ -99,7 +99,7 @@ private: ExponentialBackoff backoff_; BackoffTag backoffTag_; grpc::Alarm backoffAlarm_; - std::vector> pendingReposts_; + std::vector> deferredListeners_; // typedef for function to bind a listener // This is always of the form: @@ -157,7 +157,7 @@ public: getEndpoint() const; private: - // Handle backoff alarm firing - retry deferred reposts + // Handle backoff alarm firing - retry deferred listeners void onBackoffFired();