diff mbox series

[v2,18/28] sched: update mbuf prefetch function

Message ID	20190625153217.24301-19-jasvinder.singh@intel.com (mailing list archive)
State	Changes Requested, archived
Delegated to:	Cristian Dumitrescu
Headers	From: Jasvinder Singh <jasvinder.singh@intel.com> To: dev@dpdk.org Cc: cristian.dumitrescu@intel.com, Abraham Tovar <abrahamx.tovar@intel.com>, Lukasz Krakowiak <lukaszx.krakowiak@intel.com> Date: Tue, 25 Jun 2019 16:32:07 +0100 Message-Id: <20190625153217.24301-19-jasvinder.singh@intel.com> In-Reply-To: <20190625153217.24301-1-jasvinder.singh@intel.com> References: <20190528120553.2992-2-lukaszx.krakowiak@intel.com> <20190625153217.24301-1-jasvinder.singh@intel.com> MIME-Version: 1.0 Content-Transfer-Encoding: 8bit Subject: [dpdk-dev] [PATCH v2 18/28] sched: update mbuf prefetch function Precedence: list Errors-To: dev-bounces@dpdk.org Sender: "dev" <dev-bounces@dpdk.org>
Series	sched: feature enhancements \| [v2,00/28] sched: feature enhancements [v2,01/28] sched: update macros for flexible config [v2,02/28] sched: update subport and pipe data structures [v2,03/28] sched: update internal data structures [v2,04/28] sched: update port config API [v2,05/28] sched: update port free API [v2,06/28] sched: update subport config API [v2,07/28] sched: update pipe profile add API [v2,08/28] sched: update pipe config API [v2,09/28] sched: update pkt read and write API [v2,10/28] sched: update subport and tc queue stats [v2,11/28] sched: update port memory footprint API [v2,12/28] sched: update packet enqueue API [v2,13/28] sched: update grinder pipe and tc cache [v2,14/28] sched: update grinder next pipe and tc functions [v2,15/28] sched: update pipe and tc queues prefetch [v2,16/28] sched: update grinder wrr compute function [v2,17/28] sched: modify credits update function [v2,18/28] sched: update mbuf prefetch function [v2,19/28] sched: update grinder schedule function [v2,20/28] sched: update grinder handle function [v2,21/28] sched: update packet dequeue API [v2,22/28] sched: update sched queue stats API [v2,23/28] test/sched: update unit test [v2,24/28] net/softnic: update softnic tm function [v2,25/28] examples/qos_sched: update qos sched sample app [v2,26/28] examples/ip_pipeline: update ip pipeline sample app [v2,27/28] sched: code cleanup [v2,28/28] sched: add release note

Checks

Context	Check	Description
ci/checkpatch	success	coding style OK
ci/Intel-compilation	fail	Compilation issues

Commit Message

Jasvinder Singh June 25, 2019, 3:32 p.m. UTC

  Update mbuf prefetch function of the scheduler grinder to allow
configuration flexiblity for pipe traffic classes and queues, and
subport level configuration of the pipe parameters.

Signed-off-by: Jasvinder Singh <jasvinder.singh@intel.com>
Signed-off-by: Abraham Tovar <abrahamx.tovar@intel.com>
Signed-off-by: Lukasz Krakowiak <lukaszx.krakowiak@intel.com>
---
 lib/librte_sched/rte_sched.c | 17 ++++++++++-------
 1 file changed, 10 insertions(+), 7 deletions(-)

diff mbox series

Patch

diff --git a/lib/librte_sched/rte_sched.c b/lib/librte_sched/rte_sched.c
index 8b440637d..607fe6c18 100644
--- a/lib/librte_sched/rte_sched.c
+++ b/lib/librte_sched/rte_sched.c
@@ -2561,13 +2561,16 @@  grinder_prefetch_tc_queue_arrays(struct rte_sched_port *port, uint32_t pos)
 }
 
 static inline void
-grinder_prefetch_mbuf(struct rte_sched_port *port, uint32_t pos)
+grinder_prefetch_mbuf(struct rte_sched_subport *subport, uint32_t pos)
 {
-	struct rte_sched_grinder *grinder = port->grinder + pos;
+	struct rte_sched_grinder *grinder = subport->grinder + pos;
+	struct rte_mbuf **qbase;
 	uint32_t qpos = grinder->qpos;
-	struct rte_mbuf **qbase = grinder->qbase[qpos];
-	uint16_t qsize = grinder->qsize[qpos];
-	uint16_t qr = grinder->queue[qpos]->qr & (qsize - 1);
+	uint16_t qsize, qr;
+
+	qbase = grinder->qbase[qpos];
+	qsize = grinder->qsize[qpos];
+	qr = grinder->queue[qpos]->qr & (qsize - 1);
 
 	grinder->pkt = qbase[qr];
 	rte_prefetch0(grinder->pkt);
@@ -2612,7 +2615,7 @@  grinder_handle(struct rte_sched_port *port, uint32_t pos)
 
 	case e_GRINDER_PREFETCH_MBUF:
 	{
-		grinder_prefetch_mbuf(port, pos);
+		grinder_prefetch_mbuf(port->subport, pos);
 
 		grinder->state = e_GRINDER_READ_MBUF;
 		return 0;
@@ -2627,7 +2630,7 @@  grinder_handle(struct rte_sched_port *port, uint32_t pos)
 		/* Look for next packet within the same TC */
 		if (result && grinder->qmask) {
 			grinder_wrr(port->subport, pos);
-			grinder_prefetch_mbuf(port, pos);
+			grinder_prefetch_mbuf(port->subport, pos);
 
 			return 1;
 		}