From fbe4f7dd9feb2341ca26557b12c7dd0af554fa54 Mon Sep 17 00:00:00 2001 From: JCW Date: Thu, 2 Oct 2025 11:48:56 +0100 Subject: [PATCH] Fix formatting Signed-off-by: JCW --- src/xrpld/core/JobQueue.h | 19 +++++++++---------- src/xrpld/core/detail/JobQueue.cpp | 8 ++++++-- 2 files changed, 15 insertions(+), 12 deletions(-) diff --git a/src/xrpld/core/JobQueue.h b/src/xrpld/core/JobQueue.h index f13abccffb..8de34b594a 100644 --- a/src/xrpld/core/JobQueue.h +++ b/src/xrpld/core/JobQueue.h @@ -57,12 +57,7 @@ struct Coro_create_t class JobQueue : private Workers::Callback { public: - enum class QueueState - { - Accepting, - Stopping, - Stopped - }; + enum class QueueState { Accepting, Stopping, Stopped }; /** Coroutines must run to completion. */ class Coro : public std::enable_shared_from_this @@ -178,13 +173,14 @@ public: template bool addJob(JobType type, std::string const& name, JobHandler&& jobHandler) - requires std::is_void_v> + requires std::is_void_v> { if (queueState_ != QueueState::Accepting) { return false; } - return addJobNoStatusCheck(type, name, std::forward(jobHandler)); + return addJobNoStatusCheck( + type, name, std::forward(jobHandler)); } /** Creates a coroutine and adds a job to the queue which will run it. @@ -293,8 +289,11 @@ private: template bool - addJobNoStatusCheck(JobType type, std::string const& name, JobHandler&& jobHandler) - requires std::is_void_v> + addJobNoStatusCheck( + JobType type, + std::string const& name, + JobHandler&& jobHandler) + requires std::is_void_v> { if (auto optionalCountedJob = jobCounter_.wrap(std::forward(jobHandler))) diff --git a/src/xrpld/core/detail/JobQueue.cpp b/src/xrpld/core/detail/JobQueue.cpp index 5068587015..e0f1c0765f 100644 --- a/src/xrpld/core/detail/JobQueue.cpp +++ b/src/xrpld/core/detail/JobQueue.cpp @@ -310,7 +310,8 @@ JobQueue::stop() if (!queueState_.compare_exchange_strong(accepting, QueueState::Stopping)) { - XRPL_ASSERT(false, "Incorrect queueState, should be accepting but not!"); + XRPL_ASSERT( + false, "Incorrect queueState, should be accepting but not!"); } std::map> suspendedCoros; { @@ -327,7 +328,10 @@ JobQueue::stop() { // We don't allow any new jobs from outside when we are // stopping, but we should allow new jobs from inside the class. - addJobNoStatusCheck(coroPtr->type_, coroPtr->name_, [coroPtr]() { coroPtr->resume(); }); + addJobNoStatusCheck( + coroPtr->type_, coroPtr->name_, [coroPtr]() { + coroPtr->resume(); + }); } } }