Re: [PATCH V2 06/11] libmultipath: add "detect_pgpolicy_use_tpg" config option

[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]

 



On Tue, 2023-06-06 at 15:13 -0500, Benjamin Marzinski wrote:
> If this and "detect_pgpolicy" are both selected and ALUA is
> autodetected, the multipath device will use the "group_by_tpg" policy
> instead of the "group_by_prio" policy.
> 
> Signed-off-by: Benjamin Marzinski <bmarzins@xxxxxxxxxx>

One minor remark below.

> ---
>  libmultipath/config.c             |  2 ++
>  libmultipath/config.h             |  2 ++
>  libmultipath/configure.c          |  1 +
>  libmultipath/defaults.h           |  1 +
>  libmultipath/dict.c               | 11 +++++++++++
>  libmultipath/hwtable.c            |  1 +
>  libmultipath/libmultipath.version | 10 +++-------
>  libmultipath/propsel.c            | 24 ++++++++++++++++++++++--
>  libmultipath/propsel.h            |  1 +
>  libmultipath/structs.h            |  7 +++++++
>  multipath/multipath.conf.5        | 13 +++++++++++++
>  11 files changed, 64 insertions(+), 9 deletions(-)
> 
> diff --git a/libmultipath/config.c b/libmultipath/config.c
> index 2e742373..7b207590 100644
> --- a/libmultipath/config.c
> +++ b/libmultipath/config.c
> @@ -453,6 +453,7 @@ merge_hwe (struct hwentry * dst, struct hwentry *
> src)
>         merge_num(detect_prio);
>         merge_num(detect_checker);
>         merge_num(detect_pgpolicy);
> +       merge_num(detect_pgpolicy_use_tpg);
>         merge_num(deferred_remove);
>         merge_num(delay_watch_checks);
>         merge_num(delay_wait_checks);
> @@ -619,6 +620,7 @@ store_hwe (vector hwtable, struct hwentry * dhwe)
>         hwe->detect_prio = dhwe->detect_prio;
>         hwe->detect_checker = dhwe->detect_checker;
>         hwe->detect_pgpolicy = dhwe->detect_pgpolicy;
> +       hwe->detect_pgpolicy_use_tpg = dhwe->detect_pgpolicy_use_tpg;
>         hwe->ghost_delay = dhwe->ghost_delay;
>         hwe->vpd_vendor_id = dhwe->vpd_vendor_id;
>  
> diff --git a/libmultipath/config.h b/libmultipath/config.h
> index 014c6849..0a2c297b 100644
> --- a/libmultipath/config.h
> +++ b/libmultipath/config.h
> @@ -77,6 +77,7 @@ struct hwentry {
>         int detect_prio;
>         int detect_checker;
>         int detect_pgpolicy;
> +       int detect_pgpolicy_use_tpg;
>         int deferred_remove;
>         int delay_watch_checks;
>         int delay_wait_checks;
> @@ -173,6 +174,7 @@ struct config {
>         int detect_prio;
>         int detect_checker;
>         int detect_pgpolicy;
> +       int detect_pgpolicy_use_tpg;
>         int force_sync;
>         int deferred_remove;
>         int processed_main_config;
> diff --git a/libmultipath/configure.c b/libmultipath/configure.c
> index 366b166f..ac99edc8 100644
> --- a/libmultipath/configure.c
> +++ b/libmultipath/configure.c
> @@ -305,6 +305,7 @@ int setup_map(struct multipath *mpp, char
> **params, struct vectors *vecs)
>  
>         select_pgfailback(conf, mpp);
>         select_detect_pgpolicy(conf, mpp);
> +       select_detect_pgpolicy_use_tpg(conf, mpp);
>         select_pgpolicy(conf, mpp);
>  
>         /*
> diff --git a/libmultipath/defaults.h b/libmultipath/defaults.h
> index 8f2d2f05..b3f11d4c 100644
> --- a/libmultipath/defaults.h
> +++ b/libmultipath/defaults.h
> @@ -30,6 +30,7 @@
>  #define DEFAULT_DETECT_PRIO    DETECT_PRIO_ON
>  #define DEFAULT_DETECT_CHECKER DETECT_CHECKER_ON
>  #define DEFAULT_DETECT_PGPOLICY        DETECT_PGPOLICY_ON
> +#define
> DEFAULT_DETECT_PGPOLICY_USE_TPG        DETECT_PGPOLICY_USE_TPG_OFF
>  #define DEFAULT_DEFERRED_REMOVE        DEFERRED_REMOVE_OFF
>  #define DEFAULT_DELAY_CHECKS   NU_NO
>  #define DEFAULT_ERR_CHECKS     NU_NO
> diff --git a/libmultipath/dict.c b/libmultipath/dict.c
> index edd4923d..6b3e04a3 100644
> --- a/libmultipath/dict.c
> +++ b/libmultipath/dict.c
> @@ -876,6 +876,14 @@ declare_ovr_snprint(detect_pgpolicy,
> print_yes_no_undef)
>  declare_hw_handler(detect_pgpolicy, set_yes_no_undef)
>  declare_hw_snprint(detect_pgpolicy, print_yes_no_undef)
>  
> +declare_def_handler(detect_pgpolicy_use_tpg, set_yes_no_undef)
> +declare_def_snprint_defint(detect_pgpolicy_use_tpg,
> print_yes_no_undef,
> +                          DEFAULT_DETECT_PGPOLICY_USE_TPG)
> +declare_ovr_handler(detect_pgpolicy_use_tpg, set_yes_no_undef)
> +declare_ovr_snprint(detect_pgpolicy_use_tpg, print_yes_no_undef)
> +declare_hw_handler(detect_pgpolicy_use_tpg, set_yes_no_undef)
> +declare_hw_snprint(detect_pgpolicy_use_tpg, print_yes_no_undef)
> +
>  declare_def_handler(force_sync, set_yes_no)
>  declare_def_snprint(force_sync, print_yes_no)
>  
> @@ -2121,6 +2129,7 @@ init_keywords(vector keywords)
>         install_keyword("detect_prio", &def_detect_prio_handler,
> &snprint_def_detect_prio);
>         install_keyword("detect_checker",
> &def_detect_checker_handler, &snprint_def_detect_checker);
>         install_keyword("detect_pgpolicy",
> &def_detect_pgpolicy_handler, &snprint_def_detect_pgpolicy);
> +       install_keyword("detect_pgpolicy_use_tpg",
> &def_detect_pgpolicy_use_tpg_handler,
> &snprint_def_detect_pgpolicy_use_tpg);
>         install_keyword("force_sync", &def_force_sync_handler,
> &snprint_def_force_sync);
>         install_keyword("strict_timing", &def_strict_timing_handler,
> &snprint_def_strict_timing);
>         install_keyword("deferred_remove",
> &def_deferred_remove_handler, &snprint_def_deferred_remove);
> @@ -2212,6 +2221,7 @@ init_keywords(vector keywords)
>         install_keyword("detect_prio", &hw_detect_prio_handler,
> &snprint_hw_detect_prio);
>         install_keyword("detect_checker", &hw_detect_checker_handler,
> &snprint_hw_detect_checker);
>         install_keyword("detect_pgpolicy",
> &hw_detect_pgpolicy_handler, &snprint_hw_detect_pgpolicy);
> +       install_keyword("detect_pgpolicy_use_tpg",
> &hw_detect_pgpolicy_use_tpg_handler,
> &snprint_hw_detect_pgpolicy_use_tpg);
>         install_keyword("deferred_remove",
> &hw_deferred_remove_handler, &snprint_hw_deferred_remove);
>         install_keyword("delay_watch_checks",
> &hw_delay_watch_checks_handler, &snprint_hw_delay_watch_checks);
>         install_keyword("delay_wait_checks",
> &hw_delay_wait_checks_handler, &snprint_hw_delay_wait_checks);
> @@ -2255,6 +2265,7 @@ init_keywords(vector keywords)
>         install_keyword("detect_prio", &ovr_detect_prio_handler,
> &snprint_ovr_detect_prio);
>         install_keyword("detect_checker",
> &ovr_detect_checker_handler, &snprint_ovr_detect_checker);
>         install_keyword("detect_pgpolicy",
> &ovr_detect_pgpolicy_handler, &snprint_ovr_detect_pgpolicy);
> +       install_keyword("detect_pgpolicy_use_tpg",
> &ovr_detect_pgpolicy_use_tpg_handler,
> &snprint_ovr_detect_pgpolicy_use_tpg);
>         install_keyword("deferred_remove",
> &ovr_deferred_remove_handler, &snprint_ovr_deferred_remove);
>         install_keyword("delay_watch_checks",
> &ovr_delay_watch_checks_handler, &snprint_ovr_delay_watch_checks);
>         install_keyword("delay_wait_checks",
> &ovr_delay_wait_checks_handler, &snprint_ovr_delay_wait_checks);
> diff --git a/libmultipath/hwtable.c b/libmultipath/hwtable.c
> index 0b3e7c49..9a98a7ba 100644
> --- a/libmultipath/hwtable.c
> +++ b/libmultipath/hwtable.c
> @@ -68,6 +68,7 @@
>                 .detect_prio   = DETECT_PRIO_ON,
>                 .detect_checker = DETECT_CHECKER_ON,
>                 .detect_pgpolicy = DETECT_PGPOLICY_ON,
> +               .detect_pgpolicy_use_tpg =
> DETECT_PGPOLICY_USE_TPG_ON,

This is supposed to be the default, i.e. DETECT_PGPOLICY_USE_TPG_OFF




>                 .deferred_remove = DEFERRED_REMOVE_OFF,
>                 .delay_watch_checks = DELAY_CHECKS_OFF,
>                 .delay_wait_checks = DELAY_CHECKS_OFF,
> diff --git a/libmultipath/libmultipath.version
> b/libmultipath/libmultipath.version
> index aba1a30e..8f72c452 100644
> --- a/libmultipath/libmultipath.version
> +++ b/libmultipath/libmultipath.version
> @@ -43,7 +43,7 @@ LIBMPATHCOMMON_1.0.0 {
>         put_multipath_config;
>  };
>  
> -LIBMULTIPATH_18.0.0 {
> +LIBMULTIPATH_19.0.0 {
>  global:
>         /* symbols referenced by multipath and multipathd */
>         add_foreign;
> @@ -116,6 +116,7 @@ global:
>         get_refwwid;
>         get_state;
>         get_udev_device;
> +       get_uid;
>         get_used_hwes;
>         get_vpd_sgio;
>         group_by_prio;
> @@ -141,6 +142,7 @@ global:
>         pathcount;
>         path_discovery;
>         path_get_tpgs;
> +       pathinfo;
>         path_offline;
>         print_all_paths;
>         print_foreign_topology;
> @@ -235,9 +237,3 @@ global:
>  local:
>         *;
>  };
> -
> -LIBMULTIPATH_18.1.0 {
> -global:
> -       get_uid;
> -       pathinfo;
> -} LIBMULTIPATH_18.0.0;
> diff --git a/libmultipath/propsel.c b/libmultipath/propsel.c
> index 10b84948..df10a68f 100644
> --- a/libmultipath/propsel.c
> +++ b/libmultipath/propsel.c
> @@ -280,6 +280,22 @@ out:
>         return 0;
>  }
>  
> +int select_detect_pgpolicy_use_tpg(struct config *conf, struct
> multipath *mp)
> +{
> +       const char *origin;
> +
> +       mp_set_ovr(detect_pgpolicy_use_tpg);
> +       mp_set_hwe(detect_pgpolicy_use_tpg);
> +       mp_set_conf(detect_pgpolicy_use_tpg);
> +       mp_set_default(detect_pgpolicy_use_tpg,
> +                      DEFAULT_DETECT_PGPOLICY_USE_TPG);
> +out:
> +       condlog(3, "%s: detect_pgpolicy_use_tpg = %s %s", mp->alias,
> +               (mp->detect_pgpolicy_use_tpg ==
> DETECT_PGPOLICY_USE_TPG_ON)?
> +               "yes" : "no", origin);
> +       return 0;
> +}
> +
>  int select_pgpolicy(struct config *conf, struct multipath * mp)
>  {
>         const char *origin;
> @@ -291,7 +307,10 @@ int select_pgpolicy(struct config *conf, struct
> multipath * mp)
>                 goto out;
>         }
>         if (mp->detect_pgpolicy == DETECT_PGPOLICY_ON &&
> verify_alua_prio(mp)) {
> -               mp->pgpolicy = GROUP_BY_PRIO;
> +               if (mp->detect_pgpolicy_use_tpg ==
> DETECT_PGPOLICY_USE_TPG_ON)
> +                       mp->pgpolicy = GROUP_BY_TPG;
> +               else
> +                       mp->pgpolicy = GROUP_BY_PRIO;
>                 origin = autodetect_origin;
>                 goto out;
>         }
> @@ -301,7 +320,8 @@ int select_pgpolicy(struct config *conf, struct
> multipath * mp)
>         mp_set_conf(pgpolicy);
>         mp_set_default(pgpolicy, DEFAULT_PGPOLICY);
>  out:
> -       if (mp->pgpolicy == GROUP_BY_TPG && !verify_alua_prio(mp)) {
> +       if (mp->pgpolicy == GROUP_BY_TPG && origin !=
> autodetect_origin &&
> +           !verify_alua_prio(mp)) {
>                 mp->pgpolicy = DEFAULT_PGPOLICY;
>                 origin = "(setting: emergency fallback - not all
> paths use alua prio)";
>                 log_prio = 1;
> diff --git a/libmultipath/propsel.h b/libmultipath/propsel.h
> index 513ee6ac..73615c2f 100644
> --- a/libmultipath/propsel.h
> +++ b/libmultipath/propsel.h
> @@ -1,6 +1,7 @@
>  int select_rr_weight (struct config *conf, struct multipath * mp);
>  int select_pgfailback (struct config *conf, struct multipath * mp);
>  int select_detect_pgpolicy (struct config *conf, struct multipath *
> mp);
> +int select_detect_pgpolicy_use_tpg (struct config *conf, struct
> multipath * mp);
>  int select_pgpolicy (struct config *conf, struct multipath * mp);
>  int select_selector (struct config *conf, struct multipath * mp);
>  int select_alias (struct config *conf, struct multipath * mp);
> diff --git a/libmultipath/structs.h b/libmultipath/structs.h
> index 682a7e17..97f9de5a 100644
> --- a/libmultipath/structs.h
> +++ b/libmultipath/structs.h
> @@ -149,6 +149,12 @@ enum detect_pgpolicy_states {
>         DETECT_PGPOLICY_ON = YNU_YES,
>  };
>  
> +enum detect_pgpolicy_use_tpg_states {
> +       DETECT_PGPOLICY_USE_TPG_UNDEF = YNU_UNDEF,
> +       DETECT_PGPOLICY_USE_TPG_OFF = YNU_NO,
> +       DETECT_PGPOLICY_USE_TPG_ON = YNU_YES,
> +};
> +
>  enum deferred_remove_states {
>         DEFERRED_REMOVE_UNDEF = YNU_UNDEF,
>         DEFERRED_REMOVE_OFF = YNU_NO,
> @@ -396,6 +402,7 @@ struct multipath {
>         char wwid[WWID_SIZE];
>         char alias_old[WWID_SIZE];
>         int detect_pgpolicy;
> +       int detect_pgpolicy_use_tpg;
>         int pgpolicy;
>         pgpolicyfn *pgpolicyfn;
>         int nextpg;
> diff --git a/multipath/multipath.conf.5 b/multipath/multipath.conf.5
> index 3b25b5d4..8a0ff0d8 100644
> --- a/multipath/multipath.conf.5
> +++ b/multipath/multipath.conf.5
> @@ -254,6 +254,19 @@ The default is: \fIyes\fR
>  .
>  .
>  .TP
> +.B detect_pgpolicy_use_tpg
> +If both this and \fIdetect_pgpolicy\fR are set to \fIyes\fR and all
> path
> +devcices are configured with either the \fIalua\fR or \fIsysfs\fR
> prioritizer,
> +the multipath device will automatically use the \fIgroup_by_tpg\fR
> +path_grouping_policy. If set to \fIno\fR, the path_grouping_policy
> will be
> +selected by the method described for \fIdetect_pgpolicy\fR above.
> +.RS
> +.TP
> +The default is: \fIno\fR
> +.RE
> +.
> +.
> +.TP
>  .B pg_timeout
>  (Deprecated) This option is not supported any more, and the value is
> ignored.
>  .

--
dm-devel mailing list
dm-devel@xxxxxxxxxx
https://listman.redhat.com/mailman/listinfo/dm-devel





[Index of Archives]     [DM Crypt]     [Fedora Desktop]     [ATA RAID]     [Fedora Marketing]     [Fedora Packaging]     [Fedora SELinux]     [Yosemite Discussion]     [KDE Users]     [Fedora Docs]

  Powered by Linux