ARCHIVE/rippled
1
0
Fork 0
mirror of https://github.com/XRPLF/rippled.git synced 2025-11-27 06:25:51 +00:00
Code Issues Packages Projects Releases Wiki Activity

Make the target size more useful. Add visitor functions.

Browse Source
This commit is contained in:
JoelKatz
2013-01-07 08:47:53 -08:00
parent 265218a936
commit e9fad1a431
1 changed files with 49 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

43
src/cpp/ripple/TaggedCache.h
View File

@@ -31,6 +31,8 @@ public:
typedef boost::weak_ptr<data_type> weak_data_ptr; typedef boost::weak_ptr<data_type> weak_data_ptr;
typedef boost::shared_ptr<data_type> data_ptr; typedef boost::shared_ptr<data_type> data_ptr;
typedef bool (*visitor_func)(const c_Key&, c_Data&);
protected: protected:
typedef std::pair<time_t, data_ptr> cache_entry; typedef std::pair<time_t, data_ptr> cache_entry;
@@ -43,7 +45,7 @@ protected:
mutable boost::recursive_mutex mLock; mutable boost::recursive_mutex mLock;
std::string mName; // Used for logging std::string mName; // Used for logging
int mTargetSize; // Desired number of cache entries int mTargetSize; // Desired number of cache entries (0 = ignore)
int mTargetAge; // Desired maximum cache age int mTargetAge; // Desired maximum cache age
cache_type mCache; // Hold strong reference to recent objects cache_type mCache; // Hold strong reference to recent objects
@@ -64,6 +66,8 @@ public:
void setTargetSize(int size); void setTargetSize(int size);
void setTargetAge(int age); void setTargetAge(int age);
void sweep(); void sweep();
void visitAll(visitor_func); // Visits all tracked objects, removes selected objects
void visitCached(visitor_func); // Visits all cached objects, uncaches selected objects
bool touch(const key_type& key); bool touch(const key_type& key);
bool del(const key_type& key, bool valid); bool del(const key_type& key, bool valid);
@@ -108,6 +112,8 @@ template<typename c_Key, typename c_Data> void TaggedCache<c_Key, c_Data>::sweep
// Pass 1, remove old objects from cache // Pass 1, remove old objects from cache
int cacheRemovals = 0; int cacheRemovals = 0;
if ((mTargetSize == 0) || (mCache.size() > mTargetSize))
{
cache_iterator cit = mCache.begin(); cache_iterator cit = mCache.begin();
while (cit != mCache.end()) while (cit != mCache.end())
{ {
@@ -119,6 +125,7 @@ template<typename c_Key, typename c_Data> void TaggedCache<c_Key, c_Data>::sweep
else else
++cit; ++cit;
} }
}
// Pass 2, remove dead objects from map // Pass 2, remove dead objects from map
int mapRemovals = 0; int mapRemovals = 0;
@@ -139,6 +146,40 @@ template<typename c_Key, typename c_Data> void TaggedCache<c_Key, c_Data>::sweep
", map = " << mMap.size() << "-" << mapRemovals; ", map = " << mMap.size() << "-" << mapRemovals;
} }
template<typename c_Key, typename c_Data> void TaggedCache<c_Key, c_Data>::visitAll(visitor_func func)
{ // Visits all tracked objects, removes selected objects
boost::recursive_mutex::scoped_lock sl(mLock);
map_iterator mit = mMap.begin();
while (mit != mMap.end())
{
data_ptr cachedData = mit->second.lock();
if (!cachedData)
mMap.erase(mit++); // dead reference found
else if (func(mit->first, mit->second))
{
mCache.erase(mit->first);
mMap.erase(mit++);
}
else
++mit;
}
}
template<typename c_Key, typename c_Data> void TaggedCache<c_Key, c_Data>::visitCached(visitor_func func)
{ // Visits all cached objects, uncaches selected objects
boost::recursive_mutex::scoped_lock sl(mLock);
cache_iterator cit = mCache.begin();
while (cit != mCache.end())
{
if (func(cit->first, cit->second.second))
mCache.erase(cit++);
else
++cit;
}
}
template<typename c_Key, typename c_Data> bool TaggedCache<c_Key, c_Data>::touch(const key_type& key) template<typename c_Key, typename c_Data> bool TaggedCache<c_Key, c_Data>::touch(const key_type& key)
{ // If present, make current in cache { // If present, make current in cache
boost::recursive_mutex::scoped_lock sl(mLock); boost::recursive_mutex::scoped_lock sl(mLock);