github-mirror/mergerfs
2
0
Fork 0
mirror of https://github.com/trapexit/mergerfs.git synced 2024-11-23 14:58:34 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

ff policy tweaks

Browse Source
This commit is contained in:
Antonio SJ Musumeci 2016-02-24 12:40:02 -05:00
parent 32c4b1ad1c
commit 7c85cd906a
2 changed files with 36 additions and 17 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/policy.hpp
View File

@ -28,6 +28,8 @@
#define POLICY_FAIL -1
#define POLICY_SUCCEEDED(RV) ((RV) == POLICY_SUCCESS)
#define POLICY_FAILED(RV) ((RV) == POLICY_FAIL)
#define POLICY_FAIL_ERRNO(ERRNO) (errno=ERRNO,POLICY_FAIL)
#define POLICY_FAIL_ENOENT POLICY_FAIL_ERRNO(ENOENT)
namespace mergerfs
{

51
src/policy_ff.cpp
View File

@ -31,12 +31,9 @@ using std::size_t;
static
int
_ff(const vector<string> &basepaths,
const char *fusepath,
const bool needswritablefs,
vector<const string*> &paths)
_ff_rw(const vector<string> &basepaths,
vector<const string*> &paths)
{
string fullpath;
struct statvfs st;
const string *fallback = NULL;
@ -44,12 +41,10 @@ _ff(const vector<string> &basepaths,
{
const string *basepath = &basepaths[i];
fs::path::make(basepath,fusepath,fullpath);
if(!fs::exists(fullpath,st))
if(!fs::exists(basepath->c_str(),st))
continue;
if(needswritablefs && StatVFS::readonly(st))
if(StatVFS::readonly(st))
{
if(fallback == NULL)
fallback = basepath;
@ -61,13 +56,37 @@ _ff(const vector<string> &basepaths,
return POLICY_SUCCESS;
}
if(fallback != NULL)
if(fallback == NULL)
return POLICY_FAIL_ENOENT;
paths.push_back(fallback);
return POLICY_SUCCESS;
}
static
int
_ff_ro(const vector<string> &basepaths,
const char *fusepath,
vector<const string*> &paths)
{
string fullpath;
for(size_t i = 0, ei = basepaths.size(); i != ei; i++)
{
paths.push_back(fallback);
const string *basepath = &basepaths[i];
fs::path::make(basepath,fusepath,fullpath);
if(!fs::exists(fullpath))
continue;
paths.push_back(basepath);
return POLICY_SUCCESS;
}
return (errno=ENOENT,POLICY_FAIL);
return POLICY_FAIL_ENOENT;
}
namespace mergerfs
@ -79,11 +98,9 @@ namespace mergerfs
const size_t minfreespace,
vector<const string*> &paths)
{
const char *fp =
((type == Category::Enum::create) ? "" : fusepath);
const bool needswritablefs =
(type == Category::Enum::create);
if(type == Category::Enum::create)
return _ff_rw(basepaths,paths);
return _ff(basepaths,fp,needswritablefs,paths);
return _ff_ro(basepaths,fusepath,paths);
}
}