[dm-devel] [PATCH 3/6] libmultipath: add overrides section to multipath.conf
Christophe Varoqui
christophe.varoqui at opensvc.com
Mon Jan 12 20:27:40 UTC 2015
Ben,
I have no complaints about this patch iteration, and acknowledged the need
for some users. As nobody voiced against it, I will apply the patch.
Thanks,
Christophe Varoqui
OpenSVC
On Mon, Jan 12, 2015 at 7:05 PM, Benjamin Marzinski <bmarzins at redhat.com>
wrote:
> 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 at redhat.com>
> > 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 at redhat.com>
> > ---
> > 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
>
-------------- next part --------------
An HTML attachment was scrubbed...
URL: <http://listman.redhat.com/archives/dm-devel/attachments/20150112/3d107305/attachment.htm>
More information about the dm-devel
mailing list