DPDK patches and discussions
 help / color / mirror / Atom feed
* [dpdk-dev]  [PATCH v2 1/4] app/test-eventdev: fix minor typos
@ 2018-09-04 14:12 Pavan Nikhilesh
  2018-09-04 14:12 ` [dpdk-dev] [PATCH v2 2/4] app/test-eventdev: remove redundant newlines Pavan Nikhilesh
                   ` (4 more replies)
  0 siblings, 5 replies; 22+ messages in thread
From: Pavan Nikhilesh @ 2018-09-04 14:12 UTC (permalink / raw)
  To: jerin.jacob, anoob.joseph, nikhil.rao; +Cc: dev, Pavan Nikhilesh

Fix minor typos.

Fixes: 314bcf58ca8f ("app/eventdev: add pipeline queue worker functions")

Signed-off-by: Pavan Nikhilesh <pbhagavatula@caviumnetworks.com>
---
 v2 Changes:
 - remove stray newlines in logs.
 - update pipeline description (Nikhil).
 - add Tx adapter error condition when some ethdev, eventdev pair have internal
 port capability and others don't (Nikhil).
 - cleanup code formatting, simplify worker logic.
 - update doc to reflect new pipeline flow with Tx adapter.

 app/test-eventdev/test_pipeline_atq.c    | 16 ++++++++--------
 app/test-eventdev/test_pipeline_common.h |  8 ++++----
 app/test-eventdev/test_pipeline_queue.c  | 16 ++++++++--------
 3 files changed, 20 insertions(+), 20 deletions(-)

diff --git a/app/test-eventdev/test_pipeline_atq.c b/app/test-eventdev/test_pipeline_atq.c
index 26dc79f90..f0b2f9015 100644
--- a/app/test-eventdev/test_pipeline_atq.c
+++ b/app/test-eventdev/test_pipeline_atq.c
@@ -18,7 +18,7 @@ pipeline_atq_nb_event_queues(struct evt_options *opt)
 static int
 pipeline_atq_worker_single_stage_tx(void *arg)
 {
-	PIPELINE_WROKER_SINGLE_STAGE_INIT;
+	PIPELINE_WORKER_SINGLE_STAGE_INIT;

 	while (t->done == false) {
 		uint16_t event = rte_event_dequeue_burst(dev, port, &ev, 1, 0);
@@ -43,7 +43,7 @@ pipeline_atq_worker_single_stage_tx(void *arg)
 static int
 pipeline_atq_worker_single_stage_fwd(void *arg)
 {
-	PIPELINE_WROKER_SINGLE_STAGE_INIT;
+	PIPELINE_WORKER_SINGLE_STAGE_INIT;
 	const uint8_t tx_queue = t->tx_service.queue_id;

 	while (t->done == false) {
@@ -66,7 +66,7 @@ pipeline_atq_worker_single_stage_fwd(void *arg)
 static int
 pipeline_atq_worker_single_stage_burst_tx(void *arg)
 {
-	PIPELINE_WROKER_SINGLE_STAGE_BURST_INIT;
+	PIPELINE_WORKER_SINGLE_STAGE_BURST_INIT;

 	while (t->done == false) {
 		uint16_t nb_rx = rte_event_dequeue_burst(dev, port, ev,
@@ -98,7 +98,7 @@ pipeline_atq_worker_single_stage_burst_tx(void *arg)
 static int
 pipeline_atq_worker_single_stage_burst_fwd(void *arg)
 {
-	PIPELINE_WROKER_SINGLE_STAGE_BURST_INIT;
+	PIPELINE_WORKER_SINGLE_STAGE_BURST_INIT;
 	const uint8_t tx_queue = t->tx_service.queue_id;

 	while (t->done == false) {
@@ -126,7 +126,7 @@ pipeline_atq_worker_single_stage_burst_fwd(void *arg)
 static int
 pipeline_atq_worker_multi_stage_tx(void *arg)
 {
-	PIPELINE_WROKER_MULTI_STAGE_INIT;
+	PIPELINE_WORKER_MULTI_STAGE_INIT;
 	const uint8_t nb_stages = t->opt->nb_stages;


@@ -161,7 +161,7 @@ pipeline_atq_worker_multi_stage_tx(void *arg)
 static int
 pipeline_atq_worker_multi_stage_fwd(void *arg)
 {
-	PIPELINE_WROKER_MULTI_STAGE_INIT;
+	PIPELINE_WORKER_MULTI_STAGE_INIT;
 	const uint8_t nb_stages = t->opt->nb_stages;
 	const uint8_t tx_queue = t->tx_service.queue_id;

@@ -192,7 +192,7 @@ pipeline_atq_worker_multi_stage_fwd(void *arg)
 static int
 pipeline_atq_worker_multi_stage_burst_tx(void *arg)
 {
-	PIPELINE_WROKER_MULTI_STAGE_BURST_INIT;
+	PIPELINE_WORKER_MULTI_STAGE_BURST_INIT;
 	const uint8_t nb_stages = t->opt->nb_stages;

 	while (t->done == false) {
@@ -234,7 +234,7 @@ pipeline_atq_worker_multi_stage_burst_tx(void *arg)
 static int
 pipeline_atq_worker_multi_stage_burst_fwd(void *arg)
 {
-	PIPELINE_WROKER_MULTI_STAGE_BURST_INIT;
+	PIPELINE_WORKER_MULTI_STAGE_BURST_INIT;
 	const uint8_t nb_stages = t->opt->nb_stages;
 	const uint8_t tx_queue = t->tx_service.queue_id;

diff --git a/app/test-eventdev/test_pipeline_common.h b/app/test-eventdev/test_pipeline_common.h
index 5fb91607d..9cd6b905b 100644
--- a/app/test-eventdev/test_pipeline_common.h
+++ b/app/test-eventdev/test_pipeline_common.h
@@ -65,14 +65,14 @@ struct test_pipeline {

 #define BURST_SIZE 16

-#define PIPELINE_WROKER_SINGLE_STAGE_INIT \
+#define PIPELINE_WORKER_SINGLE_STAGE_INIT \
 	struct worker_data *w  = arg;     \
 	struct test_pipeline *t = w->t;   \
 	const uint8_t dev = w->dev_id;    \
 	const uint8_t port = w->port_id;  \
 	struct rte_event ev

-#define PIPELINE_WROKER_SINGLE_STAGE_BURST_INIT \
+#define PIPELINE_WORKER_SINGLE_STAGE_BURST_INIT \
 	int i;                                  \
 	struct worker_data *w  = arg;           \
 	struct test_pipeline *t = w->t;         \
@@ -80,7 +80,7 @@ struct test_pipeline {
 	const uint8_t port = w->port_id;        \
 	struct rte_event ev[BURST_SIZE + 1]

-#define PIPELINE_WROKER_MULTI_STAGE_INIT                         \
+#define PIPELINE_WORKER_MULTI_STAGE_INIT                         \
 	struct worker_data *w  = arg;                            \
 	struct test_pipeline *t = w->t;                          \
 	uint8_t cq_id;                                           \
@@ -90,7 +90,7 @@ struct test_pipeline {
 	uint8_t *const sched_type_list = &t->sched_type_list[0]; \
 	struct rte_event ev

-#define PIPELINE_WROKER_MULTI_STAGE_BURST_INIT                   \
+#define PIPELINE_WORKER_MULTI_STAGE_BURST_INIT                   \
 	int i;                                  \
 	struct worker_data *w  = arg;                            \
 	struct test_pipeline *t = w->t;                          \
diff --git a/app/test-eventdev/test_pipeline_queue.c b/app/test-eventdev/test_pipeline_queue.c
index ca5f4578e..2e0d93d99 100644
--- a/app/test-eventdev/test_pipeline_queue.c
+++ b/app/test-eventdev/test_pipeline_queue.c
@@ -18,7 +18,7 @@ pipeline_queue_nb_event_queues(struct evt_options *opt)
 static int
 pipeline_queue_worker_single_stage_tx(void *arg)
 {
-	PIPELINE_WROKER_SINGLE_STAGE_INIT;
+	PIPELINE_WORKER_SINGLE_STAGE_INIT;

 	while (t->done == false) {
 		uint16_t event = rte_event_dequeue_burst(dev, port, &ev, 1, 0);
@@ -44,7 +44,7 @@ pipeline_queue_worker_single_stage_tx(void *arg)
 static int
 pipeline_queue_worker_single_stage_fwd(void *arg)
 {
-	PIPELINE_WROKER_SINGLE_STAGE_INIT;
+	PIPELINE_WORKER_SINGLE_STAGE_INIT;
 	const uint8_t tx_queue = t->tx_service.queue_id;

 	while (t->done == false) {
@@ -67,7 +67,7 @@ pipeline_queue_worker_single_stage_fwd(void *arg)
 static int
 pipeline_queue_worker_single_stage_burst_tx(void *arg)
 {
-	PIPELINE_WROKER_SINGLE_STAGE_BURST_INIT;
+	PIPELINE_WORKER_SINGLE_STAGE_BURST_INIT;

 	while (t->done == false) {
 		uint16_t nb_rx = rte_event_dequeue_burst(dev, port, ev,
@@ -101,7 +101,7 @@ pipeline_queue_worker_single_stage_burst_tx(void *arg)
 static int
 pipeline_queue_worker_single_stage_burst_fwd(void *arg)
 {
-	PIPELINE_WROKER_SINGLE_STAGE_BURST_INIT;
+	PIPELINE_WORKER_SINGLE_STAGE_BURST_INIT;
 	const uint8_t tx_queue = t->tx_service.queue_id;

 	while (t->done == false) {
@@ -130,7 +130,7 @@ pipeline_queue_worker_single_stage_burst_fwd(void *arg)
 static int
 pipeline_queue_worker_multi_stage_tx(void *arg)
 {
-	PIPELINE_WROKER_MULTI_STAGE_INIT;
+	PIPELINE_WORKER_MULTI_STAGE_INIT;
 	const uint8_t nb_stages = t->opt->nb_stages + 1;

 	while (t->done == false) {
@@ -165,7 +165,7 @@ pipeline_queue_worker_multi_stage_tx(void *arg)
 static int
 pipeline_queue_worker_multi_stage_fwd(void *arg)
 {
-	PIPELINE_WROKER_MULTI_STAGE_INIT;
+	PIPELINE_WORKER_MULTI_STAGE_INIT;
 	const uint8_t nb_stages = t->opt->nb_stages + 1;
 	const uint8_t tx_queue = t->tx_service.queue_id;

@@ -196,7 +196,7 @@ pipeline_queue_worker_multi_stage_fwd(void *arg)
 static int
 pipeline_queue_worker_multi_stage_burst_tx(void *arg)
 {
-	PIPELINE_WROKER_MULTI_STAGE_BURST_INIT;
+	PIPELINE_WORKER_MULTI_STAGE_BURST_INIT;
 	const uint8_t nb_stages = t->opt->nb_stages + 1;

 	while (t->done == false) {
@@ -240,7 +240,7 @@ pipeline_queue_worker_multi_stage_burst_tx(void *arg)
 static int
 pipeline_queue_worker_multi_stage_burst_fwd(void *arg)
 {
-	PIPELINE_WROKER_MULTI_STAGE_BURST_INIT;
+	PIPELINE_WORKER_MULTI_STAGE_BURST_INIT;
 	const uint8_t nb_stages = t->opt->nb_stages + 1;
 	const uint8_t tx_queue = t->tx_service.queue_id;

--
2.18.0

^ permalink raw reply	[flat|nested] 22+ messages in thread

end of thread, other threads:[~2018-09-28 16:13 UTC | newest]

Thread overview: 22+ messages (download: mbox.gz / follow: Atom feed)
-- links below jump to the message on this page --
2018-09-04 14:12 [dpdk-dev] [PATCH v2 1/4] app/test-eventdev: fix minor typos Pavan Nikhilesh
2018-09-04 14:12 ` [dpdk-dev] [PATCH v2 2/4] app/test-eventdev: remove redundant newlines Pavan Nikhilesh
2018-09-04 14:12 ` [dpdk-dev] [PATCH v2 3/4] app/test-eventdev: add Tx adapter support Pavan Nikhilesh
2018-09-05  6:54   ` Rao, Nikhil
2018-09-05  8:54     ` Pavan Nikhilesh
2018-09-05  9:37       ` Rao, Nikhil
2018-09-04 14:12 ` [dpdk-dev] [PATCH v2 4/4] doc: update eventdev application guide Pavan Nikhilesh
2018-09-19 22:22 ` [dpdk-dev] [PATCH v3 1/4] app/test-eventdev: fix minor typos Pavan Nikhilesh
2018-09-19 22:22   ` [dpdk-dev] [PATCH v3 2/4] app/test-eventdev: remove redundant newlines Pavan Nikhilesh
2018-09-23 10:31     ` Jerin Jacob
2018-09-19 22:22   ` [dpdk-dev] [PATCH v3 3/4] app/test-eventdev: add Tx adapter support Pavan Nikhilesh
2018-09-23 11:35     ` Jerin Jacob
2018-09-24  8:30       ` Andrzej Ostruszka
2018-09-24 14:45         ` Jerin Jacob
2018-09-19 22:22   ` [dpdk-dev] [PATCH v3 4/4] doc: update eventdev application guide Pavan Nikhilesh
2018-09-23 10:46     ` Jerin Jacob
2018-09-23 10:28   ` [dpdk-dev] [PATCH v3 1/4] app/test-eventdev: fix minor typos Jerin Jacob
2018-09-24  8:02 ` [dpdk-dev] [PATCH v4 " Pavan Nikhilesh
2018-09-24  8:02   ` [dpdk-dev] [PATCH v4 2/4] app/test-eventdev: remove redundant newlines Pavan Nikhilesh
2018-09-24  8:02   ` [dpdk-dev] [PATCH v4 3/4] app/test-eventdev: add Tx adapter support Pavan Nikhilesh
2018-09-28 16:13     ` Jerin Jacob
2018-09-24  8:02   ` [dpdk-dev] [PATCH v4 4/4] doc: update eventdev application guide Pavan Nikhilesh

This is a public inbox, see mirroring instructions
for how to clone and mirror all data and code used for this inbox;
as well as URLs for NNTP newsgroup(s).