On Fri, Jan 09, 2015 at 12:06:29AM +0100, Christophe Varoqui wrote: > I have no strong opinion on this one : I feel like the complexity of the > parameter inheritance system is already quite complicated ... but this > addition of a new layer would likely and safely be ignored by users who > don't need it. Those who need it are surely ready to pay the price. > Does someone have objection to my applying this patch ? Christophe, I wrote this patch because you thought an "overrides" section would be more intuitive than my previous solution of a specialized "all_devs" devices section option to overwrite options on all the devices. http://www.redhat.com/archives/dm-devel/2014-September/msg00047.html Maybe this isn't exactly what you had in mind. At any rate, I'd like to have some method inside of multipath to accomplish this. -Ben > Best regards, > Christophe > On Wed, Nov 19, 2014 at 7:17 AM, Benjamin Marzinski <bmarzins@xxxxxxxxxx> > wrote: > > Sometimes users want to be able to set a configuration value for all > their > devices (for instance, they may want all devices to set no_path_retry to > fail). The builtin device configurations make this tricky, since users > need > to change each device configuration individually. To avoid that, this > patch > adds a new section to multipath.conf, "overrides".A This section has > all of > the attributes that are in both the devices and defaults section. > Attributes set in the overrides section have a higher priority that > those > in the devices section. With this section added, the multipath > configuration order now goes: > > multipaths > overrides > devices > defaults > > I also made want_user_friendly_names print out where the configuration > came > from, and I made made select_hwhandler and select_selector always strdup > the string, instead of only on the defaults.A Since multipathd will > update > the device strings from the kernel anyway, the old way just added > complexity without saving any memory. > > To store the overrides configuration, I used a hwentry structure. We may > want to make a new overrides structure, so that we set any of the > defaults > values in overrides.A That way, users could skip using defaults and > just > use overrides if they wanted. However, this would take some additional > changes to make sure that all the defaults options can undefined, which > they can't currently be. > > Signed-off-by: Benjamin Marzinski <bmarzins@xxxxxxxxxx> > --- > A libmultipath/config.cA A A |A 1 + > A libmultipath/config.hA A A |A 1 + > A libmultipath/dict.cA A A A | 98 > ++++++++++++++++++++++++++++++++++++++++++++++ > A libmultipath/print.cA A A A | 30 ++++++++++++++ > A libmultipath/print.hA A A A |A 1 + > A libmultipath/propsel.cA A A | 55 +++++++++++++++++++++----- > A libmultipath/structs.cA A A |A 9 +---- > A multipath.conf.annotatedA A | 18 ++++++++- > A multipath.conf.defaultsA A |A 2 + > A multipath.conf.syntheticA A |A 3 ++ > A multipath/main.cA A A A A A |A 6 +++ > A multipath/multipath.conf.5 | 57 +++++++++++++++++++++++++++ > A multipathd/cli_handlers.cA | 10 +++++ > A 13 files changed, 273 insertions(+), 18 deletions(-) > > diff --git a/libmultipath/config.c b/libmultipath/config.c > index bfd8ee8..7f7bd5a 100644 > --- a/libmultipath/config.c > +++ b/libmultipath/config.c > @@ -523,6 +523,7 @@ free_config (struct config * conf) > > A A A A free_mptable(conf->mptable); > A A A A free_hwtable(conf->hwtable); > +A A A A free_hwe(conf->overrides); > A A A A free_keywords(conf->keywords); > A A A A FREE(conf); > A } > diff --git a/libmultipath/config.h b/libmultipath/config.h > index c57ab31..ef1d7c3 100644 > --- a/libmultipath/config.h > +++ b/libmultipath/config.h > @@ -145,6 +145,7 @@ struct config { > A A A A vector keywords; > A A A A vector mptable; > A A A A vector hwtable; > +A A A A struct hwentry *overrides; > > A A A A vector blist_devnode; > A A A A vector blist_wwid; > diff --git a/libmultipath/dict.c b/libmultipath/dict.c > index 98cbe48..737c9b0 100644 > --- a/libmultipath/dict.c > +++ b/libmultipath/dict.c > @@ -181,6 +181,22 @@ snprint_hw_ ## option (char * buff, int len, void * > data)A A A A A \ > A A A A return function (buff, len, &hwe->option);A A A A A A > A A A A A \ > A } > > +#define declare_ovr_handler(option, function)A A A A A A A A A > A A A A \ > +static intA A A A A A A A A A A A A A A A A A A A > A A A A A A A A A A A \ > +ovr_ ## option ## _handler (vector strvec)A A A A A A A A A A > A A A A A \ > +{A A A A A A A A A A A A A A A A A A A A A A A > A A A A A A A A A A A A \ > +A A A A if (!conf->overrides)A A A A A A A A A A A A A > A A A A A A A A A \ > +A A A A A A A A return 1;A A A A A A A A A A A A A > A A A A A A A A A A A \ > +A A A A return function (strvec, &conf->overrides->option);A A A > A A A A \ > +} > + > +#define declare_ovr_snprint(option, function)A A A A A A A A A > A A A A \ > +static intA A A A A A A A A A A A A A A A A A A A > A A A A A A A A A A A \ > +snprint_ovr_ ## option (char * buff, int len, void * data)A A A A > A A A \ > +{A A A A A A A A A A A A A A A A A A A A A A A > A A A A A A A A A A A A \ > +A A A A return function (buff, len, &conf->overrides->option);A A > A A A \ > +} > + > A #define declare_mp_handler(option, function)A A A A A A A A A > A A A A A \ > A static intA A A A A A A A A A A A A A A A A A A A > A A A A A A A A A A A \ > A mp_ ## option ## _handler (vector strvec)A A A A A A A A A A > A A A A A \ > @@ -218,21 +234,29 @@ declare_def_handler(selector, set_str) > A declare_def_snprint_defstr(selector, print_str, DEFAULT_SELECTOR) > A declare_hw_handler(selector, set_str) > A declare_hw_snprint(selector, print_str) > +declare_ovr_handler(selector, set_str) > +declare_ovr_snprint(selector, print_str) > A declare_mp_handler(selector, set_str) > A declare_mp_snprint(selector, print_str) > > A declare_def_handler(uid_attribute, set_str) > A declare_def_snprint_defstr(uid_attribute, print_str, > DEFAULT_UID_ATTRIBUTE) > +declare_ovr_handler(uid_attribute, set_str) > +declare_ovr_snprint(uid_attribute, print_str) > A declare_hw_handler(uid_attribute, set_str) > A declare_hw_snprint(uid_attribute, print_str) > > A declare_def_handler(getuid, set_str) > A declare_def_snprint(getuid, print_str) > +declare_ovr_handler(getuid, set_str) > +declare_ovr_snprint(getuid, print_str) > A declare_hw_handler(getuid, set_str) > A declare_hw_snprint(getuid, print_str) > > A declare_def_handler(prio_name, set_str) > A declare_def_snprint_defstr(prio_name, print_str, DEFAULT_PRIO) > +declare_ovr_handler(prio_name, set_str) > +declare_ovr_snprint(prio_name, print_str) > A declare_hw_handler(prio_name, set_str) > A declare_hw_snprint(prio_name, print_str) > A declare_mp_handler(prio_name, set_str) > @@ -240,11 +264,15 @@ declare_mp_snprint(prio_name, print_str) > > A declare_def_handler(alias_prefix, set_str) > A declare_def_snprint_defstr(alias_prefix, print_str, > DEFAULT_ALIAS_PREFIX) > +declare_ovr_handler(alias_prefix, set_str) > +declare_ovr_snprint(alias_prefix, print_str) > A declare_hw_handler(alias_prefix, set_str) > A declare_hw_snprint(alias_prefix, print_str) > > A declare_def_handler(prio_args, set_str) > A declare_def_snprint_defstr(prio_args, print_str, DEFAULT_PRIO_ARGS) > +declare_ovr_handler(prio_args, set_str) > +declare_ovr_snprint(prio_args, print_str) > A declare_hw_handler(prio_args, set_str) > A declare_hw_snprint(prio_args, print_str) > A declare_mp_handler(prio_args, set_str) > @@ -252,6 +280,8 @@ declare_mp_snprint(prio_args, print_str) > > A declare_def_handler(features, set_str) > A declare_def_snprint_defstr(features, print_str, DEFAULT_FEATURES) > +declare_ovr_handler(features, set_str) > +declare_ovr_snprint(features, print_str) > A declare_hw_handler(features, set_str) > A declare_hw_snprint(features, print_str) > A declare_mp_handler(features, set_str) > @@ -259,11 +289,15 @@ declare_mp_snprint(features, print_str) > > A declare_def_handler(checker_name, set_str) > A declare_def_snprint_defstr(checker_name, print_str, DEFAULT_CHECKER) > +declare_ovr_handler(checker_name, set_str) > +declare_ovr_snprint(checker_name, print_str) > A declare_hw_handler(checker_name, set_str) > A declare_hw_snprint(checker_name, print_str) > > A declare_def_handler(minio, set_int) > A declare_def_snprint_defint(minio, print_int, DEFAULT_MINIO) > +declare_ovr_handler(minio, set_int) > +declare_ovr_snprint(minio, print_nonzero) > A declare_hw_handler(minio, set_int) > A declare_hw_snprint(minio, print_nonzero) > A declare_mp_handler(minio, set_int) > @@ -271,6 +305,8 @@ declare_mp_snprint(minio, print_nonzero) > > A declare_def_handler(minio_rq, set_int) > A declare_def_snprint_defint(minio_rq, print_int, DEFAULT_MINIO_RQ) > +declare_ovr_handler(minio_rq, set_int) > +declare_ovr_snprint(minio_rq, print_nonzero) > A declare_hw_handler(minio_rq, set_int) > A declare_hw_snprint(minio_rq, print_nonzero) > A declare_mp_handler(minio_rq, set_int) > @@ -296,6 +332,8 @@ declare_def_snprint(checker_timeout, print_nonzero) > > A declare_def_handler(flush_on_last_del, set_yes_no_undef) > A declare_def_snprint_defint(flush_on_last_del, print_yes_no_undef, > YNU_NO) > +declare_ovr_handler(flush_on_last_del, set_yes_no_undef) > +declare_ovr_snprint(flush_on_last_del, print_yes_no_undef) > A declare_hw_handler(flush_on_last_del, set_yes_no_undef) > A declare_hw_snprint(flush_on_last_del, print_yes_no_undef) > A declare_mp_handler(flush_on_last_del, set_yes_no_undef) > @@ -303,6 +341,8 @@ declare_mp_snprint(flush_on_last_del, > print_yes_no_undef) > > A declare_def_handler(user_friendly_names, set_yes_no_undef) > A declare_def_snprint_defint(user_friendly_names, print_yes_no_undef, > YNU_NO) > +declare_ovr_handler(user_friendly_names, set_yes_no_undef) > +declare_ovr_snprint(user_friendly_names, print_yes_no_undef) > A declare_hw_handler(user_friendly_names, set_yes_no_undef) > A declare_hw_snprint(user_friendly_names, print_yes_no_undef) > A declare_mp_handler(user_friendly_names, set_yes_no_undef) > @@ -316,11 +356,15 @@ declare_def_snprint(wwids_file, print_str) > > A declare_def_handler(retain_hwhandler, set_yes_no_undef) > A declare_def_snprint_defint(retain_hwhandler, print_yes_no_undef, > YNU_NO) > +declare_ovr_handler(retain_hwhandler, set_yes_no_undef) > +declare_ovr_snprint(retain_hwhandler, print_yes_no_undef) > A declare_hw_handler(retain_hwhandler, set_yes_no_undef) > A declare_hw_snprint(retain_hwhandler, print_yes_no_undef) > > A declare_def_handler(detect_prio, set_yes_no_undef) > A declare_def_snprint_defint(detect_prio, print_yes_no_undef, YNU_NO) > +declare_ovr_handler(detect_prio, set_yes_no_undef) > +declare_ovr_snprint(detect_prio, print_yes_no_undef) > A declare_hw_handler(detect_prio, set_yes_no_undef) > A declare_hw_snprint(detect_prio, print_yes_no_undef) > > @@ -512,6 +556,8 @@ print_fast_io_fail(char * buff, int len, void *ptr) > > A declare_def_handler(fast_io_fail, set_fast_io_fail) > A declare_def_snprint(fast_io_fail, print_fast_io_fail) > +declare_ovr_handler(fast_io_fail, set_fast_io_fail) > +declare_ovr_snprint(fast_io_fail, print_fast_io_fail) > A declare_hw_handler(fast_io_fail, set_fast_io_fail) > A declare_hw_snprint(fast_io_fail, print_fast_io_fail) > > @@ -548,6 +594,8 @@ print_dev_loss(char * buff, int len, void *ptr) > > A declare_def_handler(dev_loss, set_dev_loss) > A declare_def_snprint(dev_loss, print_dev_loss) > +declare_ovr_handler(dev_loss, set_dev_loss) > +declare_ovr_snprint(dev_loss, print_dev_loss) > A declare_hw_handler(dev_loss, set_dev_loss) > A declare_hw_snprint(dev_loss, print_dev_loss) > > @@ -583,6 +631,8 @@ print_pgpolicy(char * buff, int len, void *ptr) > > A declare_def_handler(pgpolicy, set_pgpolicy) > A declare_def_snprint_defint(pgpolicy, print_pgpolicy, DEFAULT_PGPOLICY) > +declare_ovr_handler(pgpolicy, set_pgpolicy) > +declare_ovr_snprint(pgpolicy, print_pgpolicy) > A declare_hw_handler(pgpolicy, set_pgpolicy) > A declare_hw_snprint(pgpolicy, print_pgpolicy) > A declare_mp_handler(pgpolicy, set_pgpolicy) > @@ -700,6 +750,8 @@ print_rr_weight (char * buff, int len, void *ptr) > > A declare_def_handler(rr_weight, set_rr_weight) > A declare_def_snprint_defint(rr_weight, print_rr_weight, RR_WEIGHT_NONE) > +declare_ovr_handler(rr_weight, set_rr_weight) > +declare_ovr_snprint(rr_weight, print_rr_weight) > A declare_hw_handler(rr_weight, set_rr_weight) > A declare_hw_snprint(rr_weight, print_rr_weight) > A declare_mp_handler(rr_weight, set_rr_weight) > @@ -748,6 +800,8 @@ print_pgfailback (char * buff, int len, void *ptr) > > A declare_def_handler(pgfailback, set_pgfailback) > A declare_def_snprint_defint(pgfailback, print_pgfailback, > DEFAULT_FAILBACK) > +declare_ovr_handler(pgfailback, set_pgfailback) > +declare_ovr_snprint(pgfailback, print_pgfailback) > A declare_hw_handler(pgfailback, set_pgfailback) > A declare_hw_snprint(pgfailback, print_pgfailback) > A declare_mp_handler(pgfailback, set_pgfailback) > @@ -793,6 +847,8 @@ print_no_path_retry(char * buff, int len, void *ptr) > > A declare_def_handler(no_path_retry, set_no_path_retry) > A declare_def_snprint(no_path_retry, print_no_path_retry) > +declare_ovr_handler(no_path_retry, set_no_path_retry) > +declare_ovr_snprint(no_path_retry, print_no_path_retry) > A declare_hw_handler(no_path_retry, set_no_path_retry) > A declare_hw_snprint(no_path_retry, print_no_path_retry) > A declare_mp_handler(no_path_retry, set_no_path_retry) > @@ -1061,6 +1117,25 @@ declare_hw_handler(hwhandler, set_str) > A declare_hw_snprint(hwhandler, print_str) > > A /* > + * overrides handlers > + */ > +static int > +overrides_handler(vector strvec) > +{ > +A A A A struct hwentry * overrides; > + > +A A A A overrides = alloc_hwe(); > + > +A A A A if (!overrides) > +A A A A A A A A return 1; > + > +A A A A conf->overrides = overrides; > +A A A A return 0; > +} > + > + > + > +/* > A * multipaths block handlers > A */ > A static int > @@ -1236,6 +1311,29 @@ init_keywords(void) > A A A A install_keyword("detect_prio", &hw_detect_prio_handler, > &snprint_hw_detect_prio); > A A A A install_sublevel_end(); > > +A A A A install_keyword_root("overrides", &overrides_handler); > +A A A A install_keyword("path_grouping_policy", > &ovr_pgpolicy_handler, &snprint_ovr_pgpolicy); > +A A A A install_keyword("uid_attribute", &ovr_uid_attribute_handler, > &snprint_ovr_uid_attribute); > +A A A A install_keyword("getuid_callout", &ovr_getuid_handler, > &snprint_ovr_getuid); > +A A A A install_keyword("path_selector", &ovr_selector_handler, > &snprint_ovr_selector); > +A A A A install_keyword("path_checker", &ovr_checker_name_handler, > &snprint_ovr_checker_name); > +A A A A install_keyword("checker", &ovr_checker_name_handler, NULL); > +A A A A install_keyword("alias_prefix", &ovr_alias_prefix_handler, > &snprint_ovr_alias_prefix); > +A A A A install_keyword("features", &ovr_features_handler, > &snprint_ovr_features); > +A A A A install_keyword("prio", &ovr_prio_name_handler, > &snprint_ovr_prio_name); > +A A A A install_keyword("prio_args", &ovr_prio_args_handler, > &snprint_ovr_prio_args); > +A A A A install_keyword("failback", &ovr_pgfailback_handler, > &snprint_ovr_pgfailback); > +A A A A install_keyword("rr_weight", &ovr_rr_weight_handler, > &snprint_ovr_rr_weight); > +A A A A install_keyword("no_path_retry", &ovr_no_path_retry_handler, > &snprint_ovr_no_path_retry); > +A A A A install_keyword("rr_min_io", &ovr_minio_handler, > &snprint_ovr_minio); > +A A A A install_keyword("rr_min_io_rq", &ovr_minio_rq_handler, > &snprint_ovr_minio_rq); > +A A A A install_keyword("flush_on_last_del", > &ovr_flush_on_last_del_handler, &snprint_ovr_flush_on_last_del); > +A A A A install_keyword("fast_io_fail_tmo", > &ovr_fast_io_fail_handler, &snprint_ovr_fast_io_fail); > +A A A A install_keyword("dev_loss_tmo", &ovr_dev_loss_handler, > &snprint_ovr_dev_loss); > +A A A A install_keyword("user_friendly_names", > &ovr_user_friendly_names_handler, &snprint_ovr_user_friendly_names); > +A A A A install_keyword("retain_attached_hw_handler", > &ovr_retain_hwhandler_handler, &snprint_ovr_retain_hwhandler); > +A A A A install_keyword("detect_prio", &ovr_detect_prio_handler, > &snprint_ovr_detect_prio); > + > A A A A install_keyword_root("multipaths", &multipaths_handler); > A A A A install_keyword_multi("multipath", &multipath_handler, > NULL); > A A A A install_sublevel(); > diff --git a/libmultipath/print.c b/libmultipath/print.c > index 383eae4..ade3841 100644 > --- a/libmultipath/print.c > +++ b/libmultipath/print.c > @@ -1080,6 +1080,36 @@ snprint_mptable (char * buff, int len, vector > mptable) > A } > > A extern int > +snprint_overrides (char * buff, int len, struct hwentry *overrides) > +{ > +A A A A int fwd = 0; > +A A A A int i; > +A A A A struct keyword *rootkw; > +A A A A struct keyword *kw; > + > +A A A A rootkw = find_keyword(NULL, "overrides"); > +A A A A if (!rootkw) > +A A A A A A A A return 0; > + > +A A A A fwd += snprintf(buff + fwd, len - fwd, "overrides {\n"); > +A A A A if (fwd > len) > +A A A A A A A A return len; > +A A A A if (!overrides) > +A A A A A A A A goto out; > +A A A A iterate_sub_keywords(rootkw, kw, i) { > +A A A A A A A A fwd += snprint_keyword(buff + fwd, len - fwd, > "\t%k %v\n", > +A A A A A A A A A A A A A A A A A A A kw, NULL); > +A A A A A A A A if (fwd > len) > +A A A A A A A A A A A A return len; > +A A A A } > +out: > +A A A A fwd += snprintf(buff + fwd, len - fwd, "}\n"); > +A A A A if (fwd > len) > +A A A A A A A A return len; > +A A A A return fwd; > +} > + > +extern int > A snprint_defaults (char * buff, int len) > A { > A A A A int fwd = 0; > diff --git a/libmultipath/print.h b/libmultipath/print.h > index aef182b..a3c3319 100644 > --- a/libmultipath/print.h > +++ b/libmultipath/print.h > @@ -50,6 +50,7 @@ int snprint_status (char *, int, struct vectors *); > A int snprint_devices (char *, int, struct vectors *); > A int snprint_hwtable (char *, int, vector); > A int snprint_mptable (char *, int, vector); > +int snprint_overrides (char *, int, struct hwentry *); > > A void print_multipath_topology (struct multipath * mpp, int verbosity); > A void print_path (struct path * pp, char * style); > diff --git a/libmultipath/propsel.c b/libmultipath/propsel.c > index f2ab7d2..440802c 100644 > --- a/libmultipath/propsel.c > +++ b/libmultipath/propsel.c > @@ -48,6 +48,8 @@ do {A A A A A A A A A A A A A A A A A > A A A A A A A A A A A A A A A A \ > A do_set(var, mp->mpe, mp->var, "(LUN setting)") > A #define mp_set_hwe(var)A A A A A A A A A A A A A A A A > A A A A A A A A A A A A \ > A do_set(var, mp->hwe, mp->var, "(controller setting)") > +#define mp_set_ovr(var)A A A A A A A A A A A A A A A A > A A A A A A A A A A A A \ > +do_set(var, conf->overrides, mp->var, "(overrides setting)") > A #define mp_set_conf(var)A A A A A A A A A A A A A A A > A A A A A A A A A \ > A do_set(var, conf, mp->var, "(config file default)") > A #define mp_set_default(var, value)A A A A A A A A A A A A > A A A A A A A \ > @@ -59,6 +61,8 @@ do_set(var, mpe, pp->var, "(LUN setting)") > A do_set(var, pp->hwe, pp->var, "(controller setting)") > A #define pp_set_conf(var)A A A A A A A A A A A A A A A > A A A A A A A A A \ > A do_set(var, conf, pp->var, "(config file default)") > +#define pp_set_ovr(var)A A A A A A A A A A A A A A A A > A A A A A A A A A A A A \ > +do_set(var, conf->overrides, pp->var, "(overrides setting)") > A #define pp_set_default(var, value)A A A A A A A A A A A A > A A A A A A A \ > A do_default(pp->var, value) > > @@ -130,6 +134,7 @@ select_rr_weight (struct multipath * mp) > A A A A char *origin, buff[13]; > > A A A A mp_set_mpe(rr_weight); > +A A A A mp_set_ovr(rr_weight); > A A A A mp_set_hwe(rr_weight); > A A A A mp_set_conf(rr_weight); > A A A A mp_set_default(rr_weight, RR_WEIGHT_NONE); > @@ -145,6 +150,7 @@ select_pgfailback (struct multipath * mp) > A A A A char *origin, buff[13]; > > A A A A mp_set_mpe(pgfailback); > +A A A A mp_set_ovr(pgfailback); > A A A A mp_set_hwe(pgfailback); > A A A A mp_set_conf(pgfailback); > A A A A mp_set_default(pgfailback, DEFAULT_FAILBACK); > @@ -165,6 +171,7 @@ select_pgpolicy (struct multipath * mp) > A A A A A A A A goto out; > A A A A } > A A A A mp_set_mpe(pgpolicy); > +A A A A mp_set_ovr(pgpolicy); > A A A A mp_set_hwe(pgpolicy); > A A A A mp_set_conf(pgpolicy); > A A A A mp_set_default(pgpolicy, DEFAULT_PGPOLICY); > @@ -181,10 +188,12 @@ select_selector (struct multipath * mp) > A A A A char *origin; > > A A A A mp_set_mpe(selector); > +A A A A mp_set_ovr(selector); > A A A A mp_set_hwe(selector); > A A A A mp_set_conf(selector); > -A A A A mp_set_default(selector, set_default(DEFAULT_SELECTOR)); > +A A A A mp_set_default(selector, DEFAULT_SELECTOR); > A out: > +A A A A mp->selector = STRDUP(mp->selector); > A A A A condlog(3, "%s: path_selector = \"%s\" %s", mp->alias, > mp->selector, > A A A A A A A A origin); > A A A A return 0; > @@ -195,6 +204,7 @@ select_alias_prefix (struct multipath * mp) > A { > A A A A char *origin; > > +A A A A mp_set_ovr(alias_prefix); > A A A A mp_set_hwe(alias_prefix); > A A A A mp_set_conf(alias_prefix); > A A A A mp_set_default(alias_prefix, DEFAULT_ALIAS_PREFIX); > @@ -206,19 +216,30 @@ out: > A static int > A want_user_friendly_names(struct multipath * mp) > A { > -A A A A if (mp->mpe && > -A A A A A A mp->mpe->user_friendly_names != > USER_FRIENDLY_NAMES_UNDEF) > -A A A A A A A A return (mp->mpe->user_friendly_names == > USER_FRIENDLY_NAMES_ON); > -A A A A if (mp->hwe && > -A A A A A A mp->hwe->user_friendly_names != > USER_FRIENDLY_NAMES_UNDEF) > -A A A A A A A A return (mp->hwe->user_friendly_names == > USER_FRIENDLY_NAMES_ON); > -A A A A return (conf->user_friendly_namesA == > USER_FRIENDLY_NAMES_ON); > + > +A A A A char *origin; > +A A A A int user_friendly_names; > + > +A A A A do_set(user_friendly_names, mp->mpe, user_friendly_names, > +A A A A A A A "(LUN setting)"); > +A A A A do_set(user_friendly_names, conf->overrides, > user_friendly_names, > +A A A A A A A "(overrides setting)"); > +A A A A do_set(user_friendly_names, mp->hwe, user_friendly_names, > +A A A A A A A "(controller setting)"); > +A A A A do_set(user_friendly_names, conf, user_friendly_names, > +A A A A A A A "(config file setting)"); > +A A A A do_default(user_friendly_names, USER_FRIENDLY_NAMES_OFF); > +out: > +A A A A condlog(3, "%s: user_friendly_names = %s %s", mp->wwid, > +A A A A A A A A (user_friendly_names == USER_FRIENDLY_NAMES_ON)? > "yes" : "no", > +A A A A A A A A origin); > +A A A A return (user_friendly_names == USER_FRIENDLY_NAMES_ON); > A } > > A extern int > A select_alias (struct multipath * mp) > A { > -A A A A char *origin; > +A A A A char *origin = NULL; > > A A A A if (mp->mpe && mp->mpe->alias) { > A A A A A A A A mp->alias = STRDUP(mp->mpe->alias); > @@ -261,6 +282,7 @@ select_features (struct multipath * mp) > A A A A char *origin; > > A A A A mp_set_mpe(features); > +A A A A mp_set_ovr(features); > A A A A mp_set_hwe(features); > A A A A mp_set_conf(features); > A A A A mp_set_default(features, DEFAULT_FEATURES); > @@ -287,8 +309,9 @@ select_hwhandler (struct multipath * mp) > > A A A A mp_set_hwe(hwhandler); > A A A A mp_set_conf(hwhandler); > -A A A A mp_set_default(hwhandler, set_default(DEFAULT_HWHANDLER)); > +A A A A mp_set_default(hwhandler, DEFAULT_HWHANDLER); > A out: > +A A A A mp->hwhandler = STRDUP(mp->hwhandler); > A A A A condlog(3, "%s: hardware_handler = \"%s\" %s", mp->alias, > mp->hwhandler, > A A A A A A A A origin); > A A A A return 0; > @@ -300,6 +323,7 @@ select_checker(struct path *pp) > A A A A char *origin, *checker_name; > A A A A struct checker * c = &pp->checker; > > +A A A A do_set(checker_name, conf->overrides, checker_name, > "(overrides setting)"); > A A A A do_set(checker_name, pp->hwe, checker_name, "(controller > setting)"); > A A A A do_set(checker_name, conf, checker_name, "(config file > setting)"); > A A A A do_default(checker_name, DEFAULT_CHECKER); > @@ -327,6 +351,8 @@ select_getuid (struct path * pp) > A { > A A A A char *origin; > > +A A A A pp_set_ovr(uid_attribute); > +A A A A pp_set_ovr(getuid); > A A A A pp_set_hwe(uid_attribute); > A A A A pp_set_hwe(getuid); > A A A A pp_set_conf(uid_attribute); > @@ -383,6 +409,7 @@ select_prio (struct path * pp) > A A A A } > A A A A mpe = find_mpe(pp->wwid); > A A A A set_prio(mpe, "(LUN setting)"); > +A A A A set_prio(conf->overrides, "(overrides setting)"); > A A A A set_prio(pp->hwe, "controller setting)"); > A A A A set_prio(conf, "(config file default)"); > A A A A prio_get(p, DEFAULT_PRIO, DEFAULT_PRIO_ARGS); > @@ -405,6 +432,7 @@ select_no_path_retry(struct multipath *mp) > A A A A A A A A return 0; > A A A A } > A A A A mp_set_mpe(no_path_retry); > +A A A A mp_set_ovr(no_path_retry); > A A A A mp_set_hwe(no_path_retry); > A A A A mp_set_conf(no_path_retry); > A out: > @@ -427,6 +455,7 @@ select_minio_rq (struct multipath * mp) > A A A A char *origin; > > A A A A do_set(minio_rq, mp->mpe, mp->minio, "(LUN setting)"); > +A A A A do_set(minio_rq, conf->overrides, mp->minio, "(overrides > setting)"); > A A A A do_set(minio_rq, mp->hwe, mp->minio, "(controller > setting)"); > A A A A do_set(minio_rq, conf, mp->minio, "(config file setting)"); > A A A A do_default(mp->minio, DEFAULT_MINIO_RQ); > @@ -441,6 +470,7 @@ select_minio_bio (struct multipath * mp) > A A A A char *origin; > > A A A A mp_set_mpe(minio); > +A A A A mp_set_ovr(minio); > A A A A mp_set_hwe(minio); > A A A A mp_set_conf(minio); > A A A A mp_set_default(minio, DEFAULT_MINIO); > @@ -465,6 +495,7 @@ select_fast_io_fail(struct multipath *mp) > A { > A A A A char *origin, buff[12]; > > +A A A A mp_set_ovr(fast_io_fail); > A A A A mp_set_hwe(fast_io_fail); > A A A A mp_set_conf(fast_io_fail); > A A A A mp_set_default(fast_io_fail, DEFAULT_FAST_IO_FAIL); > @@ -479,6 +510,7 @@ select_dev_loss(struct multipath *mp) > A { > A A A A char *origin, buff[12]; > > +A A A A mp_set_ovr(dev_loss); > A A A A mp_set_hwe(dev_loss); > A A A A mp_set_conf(dev_loss); > A A A A mp->dev_loss = 0; > @@ -497,6 +529,7 @@ select_flush_on_last_del(struct multipath *mp) > A A A A if (mp->flush_on_last_del == FLUSH_IN_PROGRESS) > A A A A A A A A return 0; > A A A A mp_set_mpe(flush_on_last_del); > +A A A A mp_set_ovr(flush_on_last_del); > A A A A mp_set_hwe(flush_on_last_del); > A A A A mp_set_conf(flush_on_last_del); > A A A A mp_set_default(flush_on_last_del, FLUSH_DISABLED); > @@ -532,6 +565,7 @@ select_retain_hwhandler (struct multipath * mp) > A A A A A A A A origin = "(requires kernel version >= 1.5.0)"; > A A A A A A A A goto out; > A A A A } > +A A A A mp_set_ovr(retain_hwhandler); > A A A A mp_set_hwe(retain_hwhandler); > A A A A mp_set_conf(retain_hwhandler); > A A A A mp_set_default(retain_hwhandler, DEFAULT_RETAIN_HWHANDLER); > @@ -547,6 +581,7 @@ select_detect_prio (struct path * pp) > A { > A A A A char *origin; > > +A A A A pp_set_ovr(detect_prio); > A A A A pp_set_hwe(detect_prio); > A A A A pp_set_conf(detect_prio); > A A A A pp_set_default(detect_prio, DEFAULT_DETECT_PRIO); > diff --git a/libmultipath/structs.c b/libmultipath/structs.c > index 30d247d..0538327 100644 > --- a/libmultipath/structs.c > +++ b/libmultipath/structs.c > @@ -206,10 +206,7 @@ free_multipath_attributes (struct multipath * mpp) > A A A A if (!mpp) > A A A A A A A A return; > > -A A A A if (mpp->selector && > -A A A A A A mpp->selector != conf->selector && > -A A A A A A (!mpp->mpe || (mpp->mpe && mpp->selector != > mpp->mpe->selector)) && > -A A A A A A (!mpp->hwe || (mpp->hwe && mpp->selector != > mpp->hwe->selector))) { > +A A A A if (mpp->selector) { > A A A A A A A A FREE(mpp->selector); > A A A A A A A A mpp->selector = NULL; > A A A A } > @@ -219,9 +216,7 @@ free_multipath_attributes (struct multipath * mpp) > A A A A A A A A mpp->features = NULL; > A A A A } > > -A A A A if (mpp->hwhandler && > -A A A A A A mpp->hwhandler != conf->hwhandler && > -A A A A A A (!mpp->hwe || (mpp->hwe && mpp->hwhandler != > mpp->hwe->hwhandler))) { > +A A A A if (mpp->hwhandler) { > A A A A A A A A FREE(mpp->hwhandler); > A A A A A A A A mpp->hwhandler = NULL; > A A A A } > diff --git a/multipath.conf.annotated b/multipath.conf.annotated > index 0af1d4c..71afc0a 100644 > --- a/multipath.conf.annotated > +++ b/multipath.conf.annotated > @@ -485,7 +485,8 @@ > A ## scope : multipath & multipathd > A ## descA : list of per storage controller settings > A ##A A A A overrides default settings (device_maps block) > -##A A A A A overriden by per multipath settings (multipaths block) > +##A A A A overriden by per multipath settings (multipaths block) > +##A A A A and the overrides settings (overrides block) > A ## > A #devices { > A #A A A # > @@ -651,3 +652,18 @@ > A #A A A A A A A rr_weightA A A A A A A A priorities > A #A A A } > A #} > +# > +## > +## nameA : devices > +## scope : multipath & multipathd > +## descA : list of settings to override all hadware settings for all > devices > +##A A A A overrides default settings (device_maps block) > +##A A A A and per device type settings (devices block) > +##A A A A overriden by per multipath settings (multipaths block) > +## > +#A A A attributes and values are identical to the device block > +# > +#overrides { > +#A A A dev_loss_tmoA A A A A A 60 > +#A A A no_path_retryA A A A A A fail > +#} > diff --git a/multipath.conf.defaults b/multipath.conf.defaults > index 654be97..1c65e02 100644 > --- a/multipath.conf.defaults > +++ b/multipath.conf.defaults > @@ -912,3 +912,5 @@ > A #} > A #multipaths { > A #} > +#overrides { > +#} > diff --git a/multipath.conf.synthetic b/multipath.conf.synthetic > index bda1b75..f7b9b8a 100644 > --- a/multipath.conf.synthetic > +++ b/multipath.conf.synthetic > @@ -72,3 +72,6 @@ > A #A A A A A A A path_grouping_policyA A multibus > A #A A A } > A #} > +#overrides { > +#A A A no_path_retryA A A A A A A A A A fail > +#} > diff --git a/multipath/main.c b/multipath/main.c > index fd6262f..ea453b4 100644 > --- a/multipath/main.c > +++ b/multipath/main.c > @@ -405,6 +405,12 @@ dump_config (void) > A A A A A A A A A A A A reply = REALLOC(reply, maxlen *= 2); > A A A A A A A A A A A A continue; > A A A A A A A A } > +A A A A A A A A c += snprint_overrides(c, reply + maxlen - c, > conf->overrides); > +A A A A A A A A again = ((c - reply) == maxlen); > +A A A A A A A A if (again) { > +A A A A A A A A A A A A reply = REALLOC(reply, maxlen *= 2); > +A A A A A A A A A A A A continue; > +A A A A A A A A } > A A A A A A A A c += snprint_mptable(c, reply + maxlen - c, > conf->mptable); > A A A A A A A A again = ((c - reply) == maxlen); > A A A A A A A A if (again) > diff --git a/multipath/multipath.conf.5 b/multipath/multipath.conf.5 > index cadb34d..b823990 100644 > --- a/multipath/multipath.conf.5 > +++ b/multipath/multipath.conf.5 > @@ -61,6 +61,10 @@ the udev attribute given by the > A .TP > A .B devices > A This section defines the device-specific settings. > +.TP > +.B overrides > +This section defines values for attributes that should override the > +device-specific settings for all devices. > A .RE > A .LP > A .SH "defaults section" > @@ -629,6 +633,59 @@ section: > A .RE > A .PD > A .LP > +.SH "overrides section" > +The overrides section recognizes the following optional attributes; if > not set > +the values are taken from the > +.I devices > +or > +.I defaults > +sections: > +.sp 1 > +.PD .1v > +.RS > +.TP 18 > +.B path_grouping_policy > +.TP > +.B uid_attribute > +.TP > +.B getuid_callout > +.TP > +.B path_selector > +.TP > +.B path_checker > +.TP > +.B alias_prefix > +.TP > +.B features > +.TP > +.B prio > +.TP > +.B prio_args > +.TP > +.B failback > +.TP > +.B rr_weight > +.TP > +.B no_path_retry > +.TP > +.B rr_min_io > +.TP > +.B rr_min_io_rq > +.TP > +.B flush_on_last_del > +.TP > +.B fast_io_fail_tmo > +.TP > +.B dev_loss_tmo > +.TP > +.B user_friendly_names > +.TP > +.B retain_attached_hw_handler > +.TP > +.B detect_prio > +.RE > +.PD > +.LP > A .SH "KNOWN ISSUES" > A The usage of > A .B queue_if_no_path > diff --git a/multipathd/cli_handlers.c b/multipathd/cli_handlers.c > index b086340..0ce1408 100644 > --- a/multipathd/cli_handlers.c > +++ b/multipathd/cli_handlers.c > @@ -190,6 +190,16 @@ show_config (char ** r, int * len) > A A A A A A A A A A A A maxlen *= 2; > A A A A A A A A A A A A continue; > A A A A A A A A } > +A A A A A A A A c += snprint_overrides(c, reply + maxlen - c, > conf->overrides); > +A A A A A A A A again = ((c - reply) == maxlen); > +A A A A A A A A if (again) { > +A A A A A A A A A A A A reply = REALLOC(reply, maxlen * 2); > +A A A A A A A A A A A A if (!reply) > +A A A A A A A A A A A A A A A A return 1; > +A A A A A A A A A A A A memset(reply + maxlen, 0, maxlen); > +A A A A A A A A A A A A maxlen *= 2; > +A A A A A A A A A A A A continue; > +A A A A A A A A } > A A A A A A A A c += snprint_mptable(c, reply + maxlen - c, > conf->mptable); > A A A A A A A A again = ((c - reply) == maxlen); > A A A A A A A A REALLOC_REPLY(reply, again, maxlen); > -- > 1.8.3.1 -- dm-devel mailing list dm-devel@xxxxxxxxxx https://www.redhat.com/mailman/listinfo/dm-devel
