[<prev] [next>] [<thread-prev] [thread-next>] [day] [month] [year] [list]
Message-Id: <20210626003314.3159402-5-vinicius.gomes@intel.com>
Date: Fri, 25 Jun 2021 17:33:06 -0700
From: Vinicius Costa Gomes <vinicius.gomes@...el.com>
To: netdev@...r.kernel.org
Cc: Vinicius Costa Gomes <vinicius.gomes@...el.com>, jhs@...atatu.com,
xiyou.wangcong@...il.com, jiri@...nulli.us, kuba@...nel.org,
vladimir.oltean@....com, po.liu@....com,
intel-wired-lan@...ts.osuosl.org, anthony.l.nguyen@...el.com,
mkubecek@...e.cz
Subject: [PATCH net-next v4 04/12] taprio: Replace tc_map_to_queue_mask()
Replaces tc_map_to_queue_mask() by netdev_tc_map_to_queue_mask() that
was just introduced.
Signed-off-by: Vinicius Costa Gomes <vinicius.gomes@...el.com>
---
net/sched/sch_taprio.c | 26 ++++----------------------
1 file changed, 4 insertions(+), 22 deletions(-)
diff --git a/net/sched/sch_taprio.c b/net/sched/sch_taprio.c
index 58586f98c648..4e411ca3a9eb 100644
--- a/net/sched/sch_taprio.c
+++ b/net/sched/sch_taprio.c
@@ -1201,25 +1201,6 @@ static void taprio_offload_config_changed(struct taprio_sched *q)
spin_unlock(&q->current_entry_lock);
}
-static u32 tc_map_to_queue_mask(struct net_device *dev, u32 tc_mask)
-{
- u32 i, queue_mask = 0;
-
- for (i = 0; i < dev->num_tc; i++) {
- u32 offset, count;
-
- if (!(tc_mask & BIT(i)))
- continue;
-
- offset = dev->tc_to_txq[i].offset;
- count = dev->tc_to_txq[i].count;
-
- queue_mask |= GENMASK(offset + count - 1, offset);
- }
-
- return queue_mask;
-}
-
static void taprio_sched_to_offload(struct net_device *dev,
struct sched_gate_list *sched,
struct tc_taprio_qopt_offload *offload)
@@ -1236,7 +1217,7 @@ static void taprio_sched_to_offload(struct net_device *dev,
e->command = entry->command;
e->interval = entry->interval;
- e->gate_mask = tc_map_to_queue_mask(dev, entry->gate_mask);
+ e->gate_mask = netdev_tc_map_to_queue_mask(dev, entry->gate_mask);
i++;
}
@@ -1536,14 +1517,15 @@ static int taprio_change(struct Qdisc *sch, struct nlattr *opt,
if (tb[TCA_TAPRIO_ATTR_PREEMPT_TCS]) {
u32 preempt = nla_get_u32(tb[TCA_TAPRIO_ATTR_PREEMPT_TCS]);
struct tc_preempt_qopt_offload qopt = { };
+ u32 all_tcs_mask = GENMASK(mqprio->num_tc, 0);
- if (preempt == U32_MAX) {
+ if ((preempt & all_tcs_mask) == all_tcs_mask) {
NL_SET_ERR_MSG(extack, "At least one queue must be not be preemptible");
err = -EINVAL;
goto free_sched;
}
- qopt.preemptible_queues = tc_map_to_queue_mask(dev, preempt);
+ qopt.preemptible_queues = netdev_tc_map_to_queue_mask(dev, preempt);
err = dev->netdev_ops->ndo_setup_tc(dev, TC_SETUP_PREEMPT,
&qopt);
--
2.32.0
Powered by blists - more mailing lists