github-mirror/mergerfs
2
0
Fork 0
mirror of https://github.com/trapexit/mergerfs.git synced 2024-11-26 02:09:52 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

policy_cache.cpp

Browse Source
This commit is contained in:
Antonio SJ Musumeci 2024-02-15 20:03:37 -06:00
parent 213f0bb732
commit d860de35c9
1 changed files with 0 additions and 131 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

131
src/policy_cache.cpp
View File

@ -1,131 +0,0 @@
#include "policy_cache.hpp"
#include <cstdlib>
#include <map>
#include <string>
#include <time.h>
using std::map;
using std::string;
static const uint64_t DEFAULT_TIMEOUT = 0;
namespace l
{
static
uint64_t
get_time(void)
{
uint64_t rv;
rv = ::time(NULL);
return rv;
}
}
PolicyCache::Value::Value()
: time(0),
paths()
{
}
PolicyCache::PolicyCache(void)
: timeout(DEFAULT_TIMEOUT)
{
pthread_mutex_init(&_lock,NULL);
}
void
PolicyCache::erase(const char *fusepath_)
{
if(timeout == 0)
return;
pthread_mutex_lock(&_lock);
_cache.erase(fusepath_);
pthread_mutex_unlock(&_lock);
}
void
PolicyCache::cleanup(const int prob_)
{
uint64_t now;
map<string,Value>::iterator i;
if(timeout == 0)
return;
if(rand() % prob_)
return;
now = l::get_time();
pthread_mutex_lock(&_lock);
i = _cache.begin();
while(i != _cache.end())
{
if((now - i->second.time) >= timeout)
_cache.erase(i++);
else
++i;
}
pthread_mutex_unlock(&_lock);
}
void
PolicyCache::clear(void)
{
pthread_mutex_lock(&_lock);
_cache.clear();
pthread_mutex_unlock(&_lock);
}
int
PolicyCache::operator()(const Policy::Search &policy_,
const Branches &branches_,
const char *fusepath_,
StrVec *paths_)
{
int rv;
Value *v;
uint64_t now;
if(timeout == 0)
return policy_(branches_,fusepath_,paths_);
now = l::get_time();
pthread_mutex_lock(&_lock);
v = &_cache[fusepath_];
if((now - v->time) >= timeout)
{
pthread_mutex_unlock(&_lock);
rv = policy_(branches_,fusepath_,paths_);
if(rv == -1)
return -1;
pthread_mutex_lock(&_lock);
v->time = now;
v->paths = *paths_;
}
else
{
*paths_ = v->paths;
}
pthread_mutex_unlock(&_lock);
return 0;
}