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

provide 'defaults' option. closes #58

Browse Source
This commit is contained in:
Antonio SJ Musumeci 2015-03-11 18:14:05 -04:00
parent 951b22b671
commit 33c837a560
1 changed files with 86 additions and 28 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

114
src/option_parser.cpp
View File

@ -41,6 +41,80 @@ using std::string;
using std::vector; using std::vector;
using namespace mergerfs; using namespace mergerfs;
static
void
set_option(struct fuse_args &args,
const std::string &option_)
{
string option;
option = "-o" + option_;
fuse_opt_insert_arg(&args,1,option.c_str());
}
static
void
set_kv_option(struct fuse_args &args,
const std::string &key,
const std::string &value)
{
std::string option;
option = key + '=' + value;
set_option(args,option);
}
static
void
set_fsname(struct fuse_args &args,
const vector<string> &srcmounts)
{
if(srcmounts.size() > 0)
{
std::string fsname;
fsname = str::remove_common_prefix_and_join(srcmounts,':');
set_kv_option(args,"fsname",fsname);
}
}
static
void
set_subtype(struct fuse_args &args)
{
set_kv_option(args,"subtype","mergerfs");
}
static
void
set_default_options(struct fuse_args &args)
{
set_option(args,"big_writes");
set_option(args,"splice_read");
set_option(args,"splice_write");
set_option(args,"splice_move");
set_option(args,"auto_cache");
set_option(args,"atomic_o_trunc");
}
static
int
parse_and_process_arg(config::Config &config,
const std::string &arg,
struct fuse_args *outargs)
{
if(arg == "defaults")
{
set_default_options(*outargs);
return 0;
}
return 1;
}
static static
int int
parse_and_process_kv_arg(config::Config &config, parse_and_process_kv_arg(config::Config &config,
@ -54,11 +128,12 @@ parse_and_process_kv_arg(config::Config &config,
if(keypart.size() != 2) if(keypart.size() != 2)
return 1; return 1;
rv = 0;
if(keypart[0] == "func") if(keypart[0] == "func")
rv = config.set_func_policy(keypart[1],value); rv = config.set_func_policy(keypart[1],value);
else if(keypart[0] == "category") else if(keypart[0] == "category")
rv = config.set_category_policy(keypart[1],value); rv = config.set_category_policy(keypart[1],value);
else
rv = -1;
if(rv == -1) if(rv == -1)
rv = 1; rv = 1;
@ -69,14 +144,20 @@ parse_and_process_kv_arg(config::Config &config,
static static
int int
process_opt(config::Config &config, process_opt(config::Config &config,
const std::string &arg) const std::string &arg,
struct fuse_args *outargs)
{ {
int rv = 0; int rv;
std::vector<std::string> argvalue; std::vector<std::string> argvalue;
rv = 1;
str::split(argvalue,arg,'='); str::split(argvalue,arg,'=');
switch(argvalue.size()) switch(argvalue.size())
{ {
case 1:
rv = parse_and_process_arg(config,argvalue[0],outargs);
break;
case 2: case 2:
rv = parse_and_process_kv_arg(config,argvalue[0],argvalue[1]); rv = parse_and_process_kv_arg(config,argvalue[0],argvalue[1]);
break; break;
@ -126,7 +207,7 @@ option_processor(void *data,
switch(key) switch(key)
{ {
case FUSE_OPT_KEY_OPT: case FUSE_OPT_KEY_OPT:
rv = process_opt(config,arg); rv = process_opt(config,arg,outargs);
break; break;
case FUSE_OPT_KEY_NONOPT: case FUSE_OPT_KEY_NONOPT:
@ -142,29 +223,6 @@ option_processor(void *data,
return rv; return rv;
} }
static
void
set_fsname(struct fuse_args &args,
const config::Config &config)
{
if(config.srcmounts.size() > 0)
{
std::string fsname;
fsname = str::remove_common_prefix_and_join(config.srcmounts,':');
fsname = "-ofsname=" + fsname;
fuse_opt_insert_arg(&args,1,fsname.c_str());
}
}
static
void
set_subtype(struct fuse_args &args)
{
fuse_opt_insert_arg(&args,1,"-osubtype=mergerfs");
}
namespace mergerfs namespace mergerfs
{ {
namespace options namespace options
@ -179,7 +237,7 @@ namespace mergerfs
NULL, NULL,
::option_processor); ::option_processor);
set_fsname(args,config); set_fsname(args,config.srcmounts);
set_subtype(args); set_subtype(args);
} }
} }