lists.openwall.net   lists  /  announce  owl-users  owl-dev  john-users  john-dev  passwdqc-users  yescrypt  popa3d-users  /  oss-security  kernel-hardening  musl  sabotage  tlsify  passwords  /  crypt-dev  xvendor  /  Bugtraq  Full-Disclosure  linux-kernel  linux-netdev  linux-ext4  linux-hardening  linux-cve-announce  PHC 
Open Source and information security mailing list archives
 
Hash Suite: Windows password security audit tool. GUI, reports in PDF.
[<prev] [next>] [<thread-prev] [thread-next>] [day] [month] [year] [list]
Message-ID: <ede5e9a2f27bf83bfb86d3e8c4ca7b34093b99e2.camel@inf.elte.hu>
Date:   Thu, 16 Feb 2023 14:05:22 +0100
From:   Ferenc Fejes <fejes@....elte.hu>
To:     Vladimir Oltean <vladimir.oltean@....com>, netdev@...r.kernel.org
Cc:     "David S. Miller" <davem@...emloft.net>,
        Eric Dumazet <edumazet@...gle.com>,
        Jakub Kicinski <kuba@...nel.org>,
        Paolo Abeni <pabeni@...hat.com>,
        Claudiu Manoil <claudiu.manoil@....com>,
        Vinicius Costa Gomes <vinicius.gomes@...el.com>,
        Kurt Kanzenbach <kurt@...utronix.de>,
        Jacob Keller <jacob.e.keller@...el.com>,
        Jamal Hadi Salim <jhs@...atatu.com>,
        Cong Wang <xiyou.wangcong@...il.com>,
        Jiri Pirko <jiri@...nulli.us>,
        Simon Horman <simon.horman@...igine.com>
Subject: Re: [PATCH v6 net-next 02/13] net/sched: mqprio: refactor
 offloading and unoffloading to dedicated functions

Hi!

On Sat, 2023-02-04 at 15:52 +0200, Vladimir Oltean wrote:
> Some more logic will be added to mqprio offloading, so split that
> code
> up from mqprio_init(), which is already large, and create a new
> function, mqprio_enable_offload(), similar to
> taprio_enable_offload().
> Also create the opposite function mqprio_disable_offload().
> 
> Signed-off-by: Vladimir Oltean <vladimir.oltean@....com>
> Reviewed-by: Jacob Keller <jacob.e.keller@...el.com>
> Reviewed-by: Simon Horman <simon.horman@...igine.com>
> ---
> v1->v6: none
> 
>  net/sched/sch_mqprio.c | 102 ++++++++++++++++++++++++---------------
> --
>  1 file changed, 59 insertions(+), 43 deletions(-)
> 
> diff --git a/net/sched/sch_mqprio.c b/net/sched/sch_mqprio.c
> index d2d8a02ded05..3579a64da06e 100644
> --- a/net/sched/sch_mqprio.c
> +++ b/net/sched/sch_mqprio.c
> @@ -27,6 +27,61 @@ struct mqprio_sched {
>         u64 max_rate[TC_QOPT_MAX_QUEUE];
>  };
>  
> +static int mqprio_enable_offload(struct Qdisc *sch,
> +                                const struct tc_mqprio_qopt *qopt)
> +{
> +       struct tc_mqprio_qopt_offload mqprio = {.qopt = *qopt};
> +       struct mqprio_sched *priv = qdisc_priv(sch);
> +       struct net_device *dev = qdisc_dev(sch);
> +       int err, i;
> +
> +       switch (priv->mode) {
> +       case TC_MQPRIO_MODE_DCB:
> +               if (priv->shaper != TC_MQPRIO_SHAPER_DCB)
> +                       return -EINVAL;
> +               break;
> +       case TC_MQPRIO_MODE_CHANNEL:
> +               mqprio.flags = priv->flags;
> +               if (priv->flags & TC_MQPRIO_F_MODE)
> +                       mqprio.mode = priv->mode;
> +               if (priv->flags & TC_MQPRIO_F_SHAPER)
> +                       mqprio.shaper = priv->shaper;
> +               if (priv->flags & TC_MQPRIO_F_MIN_RATE)
> +                       for (i = 0; i < mqprio.qopt.num_tc; i++)
> +                               mqprio.min_rate[i] = priv-
> >min_rate[i];
> +               if (priv->flags & TC_MQPRIO_F_MAX_RATE)
> +                       for (i = 0; i < mqprio.qopt.num_tc; i++)
> +                               mqprio.max_rate[i] = priv-
> >max_rate[i];
> +               break;
> +       default:
> +               return -EINVAL;
> +       }
> +
> +       err = dev->netdev_ops->ndo_setup_tc(dev,
> TC_SETUP_QDISC_MQPRIO,
> +                                           &mqprio);
> +       if (err)
> +               return err;
> +
> +       priv->hw_offload = mqprio.qopt.hw;
> +
> +       return 0;
> +}
> +
> +static void mqprio_disable_offload(struct Qdisc *sch)
> +{
> +       struct tc_mqprio_qopt_offload mqprio = { { 0 } };
> +       struct mqprio_sched *priv = qdisc_priv(sch);
> +       struct net_device *dev = qdisc_dev(sch);
> +
> +       switch (priv->mode) {
> +       case TC_MQPRIO_MODE_DCB:
> +       case TC_MQPRIO_MODE_CHANNEL:
> +               dev->netdev_ops->ndo_setup_tc(dev,
> TC_SETUP_QDISC_MQPRIO,
> +                                             &mqprio);
> +               break;
> +       }
> +}
> +
>  static void mqprio_destroy(struct Qdisc *sch)
>  {
>         struct net_device *dev = qdisc_dev(sch);
> @@ -41,22 +96,10 @@ static void mqprio_destroy(struct Qdisc *sch)
>                 kfree(priv->qdiscs);
>         }
>  
> -       if (priv->hw_offload && dev->netdev_ops->ndo_setup_tc) {
> -               struct tc_mqprio_qopt_offload mqprio = { { 0 } };
> -
> -               switch (priv->mode) {
> -               case TC_MQPRIO_MODE_DCB:
> -               case TC_MQPRIO_MODE_CHANNEL:
> -                       dev->netdev_ops->ndo_setup_tc(dev,
> -                                                    
> TC_SETUP_QDISC_MQPRIO,
> -                                                     &mqprio);
> -                       break;
> -               default:
> -                       return;
> -               }
> -       } else {
> +       if (priv->hw_offload && dev->netdev_ops->ndo_setup_tc)
> +               mqprio_disable_offload(sch);
> +       else
>                 netdev_set_num_tc(dev, 0);
> -       }
>  }
>  
>  static int mqprio_parse_opt(struct net_device *dev, struct
> tc_mqprio_qopt *qopt)
> @@ -253,36 +296,9 @@ static int mqprio_init(struct Qdisc *sch, struct
> nlattr *opt,
>          * supplied and verified mapping
>          */
>         if (qopt->hw) {
> -               struct tc_mqprio_qopt_offload mqprio = {.qopt =
> *qopt};
> -
> -               switch (priv->mode) {
> -               case TC_MQPRIO_MODE_DCB:
> -                       if (priv->shaper != TC_MQPRIO_SHAPER_DCB)
> -                               return -EINVAL;
> -                       break;
> -               case TC_MQPRIO_MODE_CHANNEL:
> -                       mqprio.flags = priv->flags;
> -                       if (priv->flags & TC_MQPRIO_F_MODE)
> -                               mqprio.mode = priv->mode;
> -                       if (priv->flags & TC_MQPRIO_F_SHAPER)
> -                               mqprio.shaper = priv->shaper;
> -                       if (priv->flags & TC_MQPRIO_F_MIN_RATE)
> -                               for (i = 0; i < mqprio.qopt.num_tc;
> i++)
> -                                       mqprio.min_rate[i] = priv-
> >min_rate[i];
> -                       if (priv->flags & TC_MQPRIO_F_MAX_RATE)
> -                               for (i = 0; i < mqprio.qopt.num_tc;
> i++)
> -                                       mqprio.max_rate[i] = priv-
> >max_rate[i];
> -                       break;
> -               default:
> -                       return -EINVAL;
> -               }
> -               err = dev->netdev_ops->ndo_setup_tc(dev,
> -                                                  
> TC_SETUP_QDISC_MQPRIO,
> -                                                   &mqprio);
> +               err = mqprio_enable_offload(sch, qopt);
>                 if (err)
>                         return err;
> -
> -               priv->hw_offload = mqprio.qopt.hw;
>         } else {
>                 netdev_set_num_tc(dev, qopt->num_tc);
>                 for (i = 0; i < qopt->num_tc; i++)

This patch just code refactoring or it modifies the default behavior of
the offloading too? I'm asking it in regards of the veth interface.
When you configure mqprio, the "hw" parameter is mandatory. By default,
it tries to configure it with "hw 1". However as a result, veth spit
back "Invalid argument" error (before your patches). Same happens after
this patch too, right?

For veth hardware offloading makes no sense, but giving the "hw 0"
argument explicitly as mqprio parameter might counterintuitive.

Best,
Ferenc

Powered by blists - more mailing lists

Powered by Openwall GNU/*/Linux Powered by OpenVZ