From 32a3f0a867b7aa01d343d1b9251805f79a9df559 Mon Sep 17 00:00:00 2001 From: JCW Date: Mon, 8 Sep 2025 14:53:29 +0100 Subject: [PATCH] Fix formatting Signed-off-by: JCW --- src/test/core/Coroutine_test.cpp | 1 - src/xrpld/core/Coro.ipp | 2 +- src/xrpld/core/JobQueue.h | 8 ++++++-- src/xrpld/core/detail/JobQueue.cpp | 5 +++-- 4 files changed, 10 insertions(+), 6 deletions(-) diff --git a/src/test/core/Coroutine_test.cpp b/src/test/core/Coroutine_test.cpp index 45ad1cf4f8..8cd746bbff 100644 --- a/src/test/core/Coroutine_test.cpp +++ b/src/test/core/Coroutine_test.cpp @@ -212,7 +212,6 @@ public: BEAST_EXPECT(shouldStop.has_value() && *shouldStop == true); } - void run() override { diff --git a/src/xrpld/core/Coro.ipp b/src/xrpld/core/Coro.ipp index bb6fa16ff4..3c547a8e93 100644 --- a/src/xrpld/core/Coro.ipp +++ b/src/xrpld/core/Coro.ipp @@ -43,7 +43,7 @@ JobQueue::Coro::Coro( yield(); if (!shouldStop()) { - fn(shared_from_this()); + fn(shared_from_this()); } #ifndef NDEBUG finished_ = true; diff --git a/src/xrpld/core/JobQueue.h b/src/xrpld/core/JobQueue.h index 883040bba4..9fcf2519b5 100644 --- a/src/xrpld/core/JobQueue.h +++ b/src/xrpld/core/JobQueue.h @@ -61,6 +61,7 @@ public: class Coro : public std::enable_shared_from_this { friend class JobQueue; + private: detail::LocalValues lvs_; JobQueue& jq_; @@ -286,9 +287,12 @@ private: if (auto coroPtr = coro.lock()) { if (auto optionalCountedJob = - jobCounter_.wrap([=]() { coroPtr->resume(); })) + jobCounter_.wrap([=]() { coroPtr->resume(); })) { - addRefCountedJob(coroPtr->type_, coroPtr->name_, std::move(*optionalCountedJob)); + addRefCountedJob( + coroPtr->type_, + coroPtr->name_, + std::move(*optionalCountedJob)); } } } diff --git a/src/xrpld/core/detail/JobQueue.cpp b/src/xrpld/core/detail/JobQueue.cpp index 1e446a32d1..a912fa1ee9 100644 --- a/src/xrpld/core/detail/JobQueue.cpp +++ b/src/xrpld/core/detail/JobQueue.cpp @@ -327,8 +327,9 @@ JobQueue::stop() // `Job::doJob` and the return of `JobQueue::processTask`. That is why // we must wait on the condition variable to make these assertions. std::unique_lock lock(m_mutex); - cv_.wait( - lock, [this] { return m_processCount == 0 && nSuspend_ == 0 && m_jobSet.empty(); }); + cv_.wait(lock, [this] { + return m_processCount == 0 && nSuspend_ == 0 && m_jobSet.empty(); + }); XRPL_ASSERT( m_processCount == 0, "ripple::JobQueue::stop : all processes completed");