| 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
| ||
|
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