ARCHIVE/rippled
1
0
Fork 0
mirror of https://github.com/XRPLF/rippled.git synced 2026-06-02 08:17:13 +00:00
Code Issues Packages Projects Releases Wiki Activity

logs for ref counts

Browse Source
This commit is contained in:
Valentin Balaschenko
2026-05-31 18:04:34 +01:00
parent 1acc42313c
commit a4abf883cf
2 changed files with 35 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

20
include/xrpl/basics/IntrusiveRefCounts.h
View File

@@ -7,6 +7,24 @@
namespace xrpl {
namespace detail {
// All-time peak strong/weak ref counts ever observed across all
// IntrusiveRefCounts instances. Read from doSweep periodically.
inline std::atomic<std::uint32_t> kPeakStrongObserved{0};
inline std::atomic<std::uint32_t> kPeakWeakObserved{0};
inline void
updateRefCountPeak(std::atomic<std::uint32_t>& peak, std::uint32_t v) noexcept
{
auto cur = peak.load(std::memory_order_relaxed);
while (v > cur && !peak.compare_exchange_weak(
cur, v, std::memory_order_relaxed))
{
// retry; cur is updated by compare_exchange_weak on failure
}
}
} // namespace detail
/** Action to perform when releasing a strong pointer.
noop: Do nothing. For example, a `noop` action will occur when a count is
@@ -413,6 +431,8 @@ inline IntrusiveRefCounts::RefCountPair::RefCountPair(IntrusiveRefCounts::FieldT
, partialDestroyStartedBit{v & kPartialDestroyStartedMask}
, partialDestroyFinishedBit{v & kPartialDestroyFinishedMask}
{
detail::updateRefCountPeak(detail::kPeakStrongObserved, strong);
detail::updateRefCountPeak(detail::kPeakWeakObserved, weak);
XRPL_ASSERT(
(strong < kCheckStrongMaxValue && weak < kCheckWeakMaxValue),
"xrpl::IntrusiveRefCounts::RefCountPair(FieldType) : inputs inside "

15
src/xrpld/app/main/Application.cpp
View File

@@ -1084,6 +1084,21 @@ public:
<< "; size after: " << cachedSLEs_.size();
}
{
auto const peakStrong =
xrpl::detail::kPeakStrongObserved.load(std::memory_order_relaxed);
auto const peakWeak =
xrpl::detail::kPeakWeakObserved.load(std::memory_order_relaxed);
constexpr std::uint32_t kStrongLimit = 65503; // kCheckStrongMaxValue
constexpr std::uint32_t kWeakLimit = 16351; // kCheckWeakMaxValue
JLOG(journal_.warn())
<< "RefCount peak since startup: "
<< "strong=" << peakStrong << "/" << kStrongLimit
<< " (" << (peakStrong * 100 / kStrongLimit) << "%); "
<< "weak=" << peakWeak << "/" << kWeakLimit
<< " (" << (peakWeak * 100 / kWeakLimit) << "%)";
}
mallocTrim("doSweep", journal_);
// Set timer to do another sweep later.