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

add readonly and minfreespace filters to all policy for creates. closes #236

Browse Source
This commit is contained in:
Antonio SJ Musumeci 2016-02-29 07:00:35 -05:00
parent 81b9918f6b
commit 14886a27f4
3 changed files with 51 additions and 18 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
src/fs.cpp
View File

@ -89,6 +89,17 @@ namespace fs
return exists_on_rw_fs(path,st);
}
bool
exists_on_rw_fs_with_at_least(const string &path,
const size_t minfreespace)
{
struct statvfs st;
return (exists_on_rw_fs(path,st)
&&
StatVFS::spaceavail(st) >= minfreespace);
}
void
findallfiles(const vector<string> &srcmounts,
const char *fusepath,

3
src/fs.hpp
View File

@ -36,6 +36,9 @@ namespace fs
struct statvfs &st);
bool exists_on_rw_fs(const string &path);
bool exists_on_rw_fs_with_at_least(const string &path,
const size_t minfreespace);
void findallfiles(const vector<string> &srcmounts,
const char *fusepath,
vector<string> &paths);

55
src/policy_all.cpp
View File

@ -29,27 +29,48 @@ using std::size_t;
static
int
_all(const vector<string> &basepaths,
const char *fusepath,
const bool needswritablefs,
vector<const string*> &paths)
_all_create(const vector<string> &srcmounts,
const size_t minfreespace,
vector<const string*> &paths)
{
string fullpath;
for(size_t i = 0, ei = basepaths.size(); i != ei; i++)
for(size_t i = 0, ei = srcmounts.size(); i != ei; i++)
{
const string *basepath = &basepaths[i];
const string *basepath = &srcmounts[i];
fs::path::make(basepath,fusepath,fullpath);
if(!fs::available(fullpath,needswritablefs))
if(!fs::exists_on_rw_fs_with_at_least(*basepath,minfreespace))
continue;
paths.push_back(basepath);
}
if(paths.empty())
return (errno=ENOENT,POLICY_FAIL);
return POLICY_FAIL_ENOENT;
return POLICY_SUCCESS;
}
static
int
_all(const vector<string> &srcmounts,
const char *fusepath,
vector<const string*> &paths)
{
string fullpath;
for(size_t i = 0, ei = srcmounts.size(); i != ei; i++)
{
const string *basepath = &srcmounts[i];
fs::path::make(basepath,fusepath,fullpath);
if(!fs::exists(fullpath))
continue;
paths.push_back(basepath);
}
if(paths.empty())
return POLICY_FAIL_ENOENT;
return POLICY_SUCCESS;
}
@ -58,16 +79,14 @@ namespace mergerfs
{
int
Policy::Func::all(const Category::Enum::Type type,
const vector<string> &basepaths,
const vector<string> &srcmounts,
const char *fusepath,
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 _all_create(srcmounts,minfreespace,paths);
return _all(basepaths,fp,needswritablefs,paths);
return _all(srcmounts,fusepath,paths);
}
}