ARCHIVE/rippled
1
0
Fork 0
mirror of https://github.com/XRPLF/rippled.git synced 2025-11-07 20:55:53 +00:00
Code Issues Packages Projects Releases Wiki Activity

tg stats

Browse Source
This commit is contained in:
Valentin Balaschenko
2025-08-25 13:55:28 +01:00
parent 58dd07bbdf
commit 2107b09445
1 changed files with 43 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

43
include/xrpl/basics/TaggedCache.ipp
View File

@@ -107,6 +107,10 @@ TaggedCache<
KeyEqual,
Mutex>::size() const
{
static unsigned long call_count{0};
JLOG(m_journal.debug()) << "TaggedCache (" << m_name << ") lock stats,"
<< ", size, call_count = " << call_count++;
std::size_t totalSize = 0;
for (size_t i = 0; i < partitionLocks_.size(); ++i)
{
@@ -239,6 +243,11 @@ TaggedCache<
KeyEqual,
Mutex>::touch_if_exists(KeyComparable const& key)
{
static unsigned long call_count{0};
JLOG(m_journal.debug())
<< "TaggedCache (" << m_name << ") lock stats,"
<< ", touch_if_exists, call_count = " << call_count++;
std::lock_guard<Mutex> lock(lockPartition(key));
auto const iter(m_cache.find(key));
if (iter == m_cache.end())
@@ -353,6 +362,10 @@ TaggedCache<
// Remove from cache, if !valid, remove from map too. Returns true if
// removed from cache
static unsigned long call_count{0};
JLOG(m_journal.debug()) << "TaggedCache (" << m_name << ") lock stats,"
<< ", del, call_count = " << call_count++;
std::lock_guard<Mutex> lock(lockPartition(key));
auto cit = m_cache.find(key);
@@ -405,6 +418,10 @@ TaggedCache<
// Return canonical value, store if needed, refresh in cache
// Return values: true=we had the data already
static unsigned long call_count{0};
JLOG(m_journal.debug()) << "TaggedCache (" << m_name << ") lock stats,"
<< ", canonicalize, call_count = " << call_count++;
std::lock_guard<Mutex> lock(lockPartition(key));
auto cit = m_cache.find(key);
if (cit == m_cache.end())
@@ -543,6 +560,10 @@ TaggedCache<
KeyEqual,
Mutex>::fetch(key_type const& key)
{
static unsigned long call_count{0};
JLOG(m_journal.debug()) << "TaggedCache (" << m_name << ") lock stats,"
<< ", fetch, call_count = " << call_count++;
std::lock_guard<Mutex> lock(lockPartition(key));
auto ret = initialFetch(key);
@@ -611,6 +632,10 @@ TaggedCache<
Mutex>::insert(key_type const& key)
-> std::enable_if_t<IsKeyCache, ReturnType>
{
static unsigned long call_count{0};
JLOG(m_journal.debug()) << "TaggedCache (" << m_name << ") lock stats,"
<< ", insert, call_count = " << call_count++;
clock_type::time_point const now(m_clock.now());
std::lock_guard<Mutex> lock(lockPartition(key));
auto [it, inserted] = m_cache.emplace(
@@ -672,6 +697,10 @@ TaggedCache<
KeyEqual,
Mutex>::getKeys() const -> std::vector<key_type>
{
static unsigned long call_count{0};
JLOG(m_journal.debug()) << "TaggedCache (" << m_name << ") lock stats,"
<< ", getKeys, call_count = " << call_count++;
std::vector<key_type> v;
{
@@ -736,6 +765,10 @@ TaggedCache<
KeyEqual,
Mutex>::fetch(key_type const& digest, Handler const& h)
{
static unsigned long call_count{0};
JLOG(m_journal.debug()) << "TaggedCache (" << m_name << ") lock stats,"
<< ", fetch, call_count = " << call_count++;
std::lock_guard<Mutex> lock(lockPartition(digest));
if (auto ret = initialFetch(digest))
@@ -869,6 +902,11 @@ TaggedCache<
int cacheRemovals = 0;
int mapRemovals = 0;
static unsigned long call_count{0};
JLOG(m_journal.debug())
<< "TaggedCache (" << m_name << ") lock stats,"
<< ", sweep-KVCache, call_count = " << call_count++;
std::lock_guard<Mutex> lock(partitionLock);
// Keep references to all the stuff we sweep
@@ -962,6 +1000,11 @@ TaggedCache<
int cacheRemovals = 0;
int mapRemovals = 0;
static unsigned long call_count{0};
JLOG(m_journal.debug())
<< "TaggedCache (" << m_name << ") lock stats,"
<< ", sweep-KCache, call_count = " << call_count++;
std::lock_guard<Mutex> lock(partitionLock);
// Keep references to all the stuff we sweep