ARCHIVE/rippled
1
0
Fork 0
mirror of https://github.com/XRPLF/rippled.git synced 2026-04-29 15:37:57 +00:00
Code Issues Packages Projects Releases Wiki Activity

renaming

Browse Source
This commit is contained in:
Valentin Balaschenko
2026-02-26 17:27:10 +00:00
parent 9db517bba8
commit c3ad4b5269
2 changed files with 13 additions and 13 deletions
Download Patch File Download Diff File Expand all files Collapse all files

22
src/xrpld/app/main/GRPCServer.cpp
View File

@@ -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<Processor>& 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<std::shared_ptr<Processor>> toRepost;
std::vector<std::shared_ptr<Processor>> 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);

4
src/xrpld/app/main/GRPCServer.h
View File

@@ -99,7 +99,7 @@ private:
ExponentialBackoff backoff_;
BackoffTag backoffTag_;
grpc::Alarm backoffAlarm_;
std::vector<std::shared_ptr<Processor>> pendingReposts_;
std::vector<std::shared_ptr<Processor>> 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();