From mboxrd@z Thu Jan 1 00:00:00 1970 Return-Path: Received: from NAM02-BL2-obe.outbound.protection.outlook.com (mail-bl2nam02on0045.outbound.protection.outlook.com [104.47.38.45]) by dpdk.org (Postfix) with ESMTP id B7D665A for ; Tue, 4 Sep 2018 16:14:34 +0200 (CEST) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=CAVIUMNETWORKS.onmicrosoft.com; s=selector1-cavium-com; h=From:Date:Subject:Message-ID:Content-Type:MIME-Version:X-MS-Exchange-SenderADCheck; bh=jHfIpYu4hxkX+5e6POvMD2EU7gqqVOKqHbLwPv8Tylw=; b=mGxYQCqk9VHXrz64GBp3xWCYfLXSZLEh7QIFE2Mp3xM+nKReFRpLJav7z+OcCliXGdFthUCAprIY0WoB0kuGa7Lp8lyrR4lV8Jq5DfcnJX0tL7iFbc4fQPNlBMxMDhkCmK9AVVKU3WgREm4l4i+ZKGx8fXhagNTTXQWCR5pybtc= Received: from ltp-pvn.caveonetworks.com (111.93.218.67) by DM6PR07MB4971.namprd07.prod.outlook.com (2603:10b6:5:25::16) with Microsoft SMTP Server (version=TLS1_2, cipher=TLS_ECDHE_RSA_WITH_AES_256_GCM_SHA384) id 15.20.1080.17; Tue, 4 Sep 2018 14:13:11 +0000 From: Pavan Nikhilesh To: jerin.jacob@caviumnetworks.com, anoob.joseph@caviumnetworks.com, nikhil.rao@intel.com Cc: dev@dpdk.org, Pavan Nikhilesh Date: Tue, 4 Sep 2018 19:42:20 +0530 Message-Id: <20180904141223.24216-1-pbhagavatula@caviumnetworks.com> X-Mailer: git-send-email 2.18.0 MIME-Version: 1.0 Content-Type: text/plain X-Originating-IP: [111.93.218.67] X-ClientProxiedBy: MA1PR01CA0099.INDPRD01.PROD.OUTLOOK.COM (2603:1096:a00:1::15) To DM6PR07MB4971.namprd07.prod.outlook.com (2603:10b6:5:25::16) X-MS-PublicTrafficType: Email X-MS-Office365-Filtering-Correlation-Id: d0e70204-2d09-4f1a-27cf-08d612708ce0 X-Microsoft-Antispam: BCL:0; PCL:0; RULEID:(7020095)(4652040)(8989137)(5600074)(711020)(2017052603328)(7153060)(7193020); SRVR:DM6PR07MB4971; X-Microsoft-Exchange-Diagnostics: 1; DM6PR07MB4971; 3:I6EqDn3vnsWWKSo5c+g8YW82NDVJjeYWN1OKgTlZq/R7nyD3GA7JeX9saPVahrDwdh+pr3eyYFxWbb5sDZpouvuxN85mfFeLELpeV8RF/UUaVz8VdJmT898NxocUNp0eMaxy5K3aoK9dK+oNweiPJsM2e6NIy8sab9Q6BNHkPBFVdGb1TVfoMtAHLZI7tRdOhjbAwKdcJSzzYP09mraVoGT/QzRzJfwY/7kKm3Wd5VKJewm7MaKBUddjHRcR27Yb; 25:cKJ2R7HNCi9c+AOom6wqV4/h9FBj3A5igng1XLuetLlMUQcQff3q9LNJ7SZq+OaO9yiD3192HFUdnj1e2yrWzLlTVKKFyhRXhCeGBkzmuFxC8i1H47vtzue8hzwDpUc6YILsNbJiqxrxEBTgaLjRUPD7hExqG6wdnwA7vnCkfegl30U9JoIeFHXPcxf7cl+8yq66KlhqNTiTMBR/5r7I2MsTcqHHsgKX+lsGOEW+soFpH72xI/0mDfNfGYX8EeW5ps0N7Cs5FTGBtBKRnaAR+uVrxkHte9DyNTUjzAe+kao49ocMjgRzjbdcyYCg2PxTJd8xxZriU0AEo5O8AHQsEg==; 31:E8zyg3N05oyNfbLWjiV2YTZ6Pmv5hbQQZSlv9Ps+E5S/aTBpu2bFPtmLHk9TrVI4j3P+vDY93RPckhSUDkeEyGSk29/dd84riib0zBTXOL9Hrq6yTH1x1XsMCv27tEV2P7Il9C7ocgNFmtC6Qit5x/xPRcDKZTsmF+tzhvQ2/pqepZ4uAn3ZQrGe8iY6YMFKpaVYCWdtYhO//NcFYUKPvEkrwxbdt0AC0ckAkiLMHhs= X-MS-TrafficTypeDiagnostic: DM6PR07MB4971: Authentication-Results: spf=none (sender IP is ) smtp.mailfrom=Pavan.Bhagavatula@cavium.com; X-Microsoft-Exchange-Diagnostics: 1; DM6PR07MB4971; 20:gDphqXxqIZ+tK2CSZBpw8gnaylEOvww1KadUichBusmWJZkRgePg3JQuLHix/27DGTs3HhJFaBQdiiF7+CM6pPWMkjDMkQ0VVVrmuDK2bNCHa50tfuJpV3wPDYJkQSL42EvgKVjNbe4Cpw5xkBZ7D8VC/GZZeNho8isXiUzyS+TYVKhHQv9P0hHksOBBmOkcFFH4maSfEBg4RxsK4m6ePC/1Sk9A/DIl30aYlJgFvgaHssBDtdM4Kzcl55dTaC9eZwsP/pTJ0Mx3ieYJya3abOiyWvjWYoaMiVobtM/HGBXJyginSImC4QzYqT6OwY2jDNUiSBXTRTFJu9eu/iRo5waK/W1Vd5RlX+rF7m8juu77/BKzd6EvmJ2KBQnELD9rfqE7IB/ZNjpGRHb4fuDa0M9hH/DNXOc8/21BMqTc8zdnw/70cGfXZOToeP9gnjW/lpIBsWMrn5DagASHiws8JwcvdtuOS9iRmAvRmkAdTqnoGL3y+X/B9Y4SwkU0NR6Tqyi26Dg7/YtxbiDWo0MciL/D2fg3oz7gb2kNV10rpCSwk/Hj77//dLQX1VXaeqltkEMU5gqd4LUwU6IquibI9Vyddk2Upxd6kUMHKpYwv40=; 4:88tLhxHk5agjde97a5Tq/cxx9wwDoEw7YnZW9+Te6fMtF5stXvcNbWr43Hc2u+kIg+hkqa7+V9tmFxJRzRjzD4/JueP0O8TGCh/Iq52K/rUbwZKpVjLbyB1Y2Wm8isIS1qkqFjXeZgk6Aesn/Lulzjgl7bVp2d53hF4VBNuLnIXuMo7TPh1330ipbiRAqogtyqCIRGP8RjnR8UvB374r8j5awYQ8mygr6k/Rcw+7ZeISFbfwo3vvkE+X+g8XnpKM4aswwn5HPVC8kDqs5afA5w== X-Microsoft-Antispam-PRVS: X-Exchange-Antispam-Report-Test: UriScan:; X-MS-Exchange-SenderADCheck: 1 X-Exchange-Antispam-Report-CFA-Test: BCL:0; PCL:0; RULEID:(8211001083)(6040522)(2401047)(8121501046)(5005006)(823301075)(93006095)(3231311)(944501410)(52105095)(3002001)(10201501046)(149027)(150027)(6041310)(20161123558120)(201703131423095)(201702281528075)(20161123555045)(201703061421075)(201703061406153)(20161123560045)(20161123564045)(20161123562045)(201708071742011)(7699049)(76991033); SRVR:DM6PR07MB4971; BCL:0; PCL:0; RULEID:; SRVR:DM6PR07MB4971; X-Forefront-PRVS: 0785459C39 X-Forefront-Antispam-Report: SFV:NSPM; SFS:(10009020)(376002)(136003)(346002)(366004)(39850400004)(396003)(199004)(189003)(575784001)(316002)(47776003)(16586007)(66066001)(107886003)(6486002)(25786009)(14444005)(26005)(53936002)(50466002)(6512007)(48376002)(4326008)(386003)(486006)(97736004)(51416003)(956004)(16526019)(1857600001)(6506007)(42882007)(2616005)(52116002)(5660300001)(476003)(81156014)(81166006)(72206003)(2906002)(50226002)(6666003)(8676002)(478600001)(36756003)(53416004)(8936002)(105586002)(106356001)(3846002)(6116002)(68736007)(1076002)(69596002)(7736002)(5009440100003)(305945005)(42262002); DIR:OUT; SFP:1101; SCL:1; SRVR:DM6PR07MB4971; H:ltp-pvn.caveonetworks.com; FPR:; SPF:None; LANG:en; PTR:InfoNoRecords; A:1; MX:1; Received-SPF: None (protection.outlook.com: cavium.com does not designate permitted sender hosts) X-Microsoft-Exchange-Diagnostics: =?us-ascii?Q?1; DM6PR07MB4971; 23:xpHBAhJCCegFD4KY1q+uZmZx+BM3fke8wS3PGlgSf?= =?us-ascii?Q?Tn2NWYtFlqh/TP6g8jakWpYqfQhIneqc5DinUtoAURyG9GMErv+qOEq2O8q+?= =?us-ascii?Q?CvcvskKEk1XykL0c6cjFLz6uT/05o7qjUpCRAmgae6FNDMCw+L/RNiWB8Q7Y?= =?us-ascii?Q?60evwFdUe/F9aWZZ7GGfFlDhddQhtEgUmtMhCKHrlciCC8aU/oeUHGQGJb6P?= =?us-ascii?Q?yExaq8qfqhk809aer5TppNBqG2zNtn+aLdVzimD7MORdDRrOAdqhIGNisAXn?= =?us-ascii?Q?plgyU6MSubZonfTScFzbMubekf2TTX/8mG1dKGk46wvCHJpH3YRF5t6L1oz+?= =?us-ascii?Q?pLuYwfFHKuxbkDs4LC65H8FsBzzY8aVIRo0sYqyXLrJiJ7fd2I6y1M38orHz?= =?us-ascii?Q?KBMTfJighsTOh5w2Xm4fYTsDdbv/V57nUiHfe2ZYkAKM7GQ6VmF1xj13okQM?= =?us-ascii?Q?dCqsMLJh1F9RCGFUDpLi2Q4khFpo6xBmi291NjAwj9x2SZ60OEzY1eITM8T1?= =?us-ascii?Q?i9t1rSUULwRskqupxn/wrqc3HxHAsj39PLUw1UE2mGBKE0kmfnnfpkk+bbCX?= =?us-ascii?Q?YkDPZtxPzKxBDVRdks1YFiFKk36ZrEVl3OVPyQ8XBQH13zNx6TwbNF7zUqZ1?= =?us-ascii?Q?ochU8eJ+HJ3TZ0XmBrZEiuR9jJ+tgUhn38aPRnxkCajz09DpeV+4+YCcHAJ7?= =?us-ascii?Q?MCUjp+sP7f4Iva0UIPQt8WsD01kY8vXrtahALIpQuReMRcKwQzCz7EqEQ2Xu?= =?us-ascii?Q?mEXtxbt4NprbOsJYJkBuHlrPYKzUsWRhNZ16FKQqn1W7jkgoslV0heO1BBJG?= =?us-ascii?Q?4NiT2coghzkKMz6UznAtV+X/k24qxzSQOHCfU5PZicFHeC3qNpX+Xa5n8uOj?= =?us-ascii?Q?iGTd2SFMNl0lE5d22EoudqFXKMI0FqkLM+N4EsjDri3E/klGwV/LExS/8xAb?= =?us-ascii?Q?MtezAIarxW1be34mplfMTW/ZTA2RHppJyPLXukv0RCRG+nHg+iK6YVcjLhIo?= =?us-ascii?Q?Zmom9z9N1U3hoS2Eqo9WCIEaD69AKuRg7Q81+EOC/VlObuGCsaa5lADjozBS?= =?us-ascii?Q?RdFARwfPCWoPEQ2keHy1kM95QC4UgH3xp2Pc8Vly1rQAm80nuD+uSTp9yZRz?= =?us-ascii?Q?zHg91jLvLSYiNE7Li3knD9w+b+i5lRITVS1lbfJPTapam4r1/7qgiRtoYG0J?= =?us-ascii?Q?shmx+554oUZ+mQOvd6fobMJo0n8FqBn3q7Scl4o3duIjDkEiRH+eDEBzqG9j?= =?us-ascii?Q?bvRioPeM6iqteVhZdtcNI9R+hk2gwvxNYZSZghupupVnO2/fT/oTESQqirgj?= =?us-ascii?B?QT09?= X-Microsoft-Antispam-Message-Info: XVQR1efoGxWUJL+g9zUAnmOAKPh99MfwXR8bK5u4oGTpBJnq/hbvn8dvHW2o9HHlY68gE1boazacnKy9cSbuGR0utl+DMZnm4+yJbzvxsgbjF9HYG6BMkJ4OTOPBAjfL7s3DkfiTINvnb3CaIcQp48O89fwPjh2XH3LZg8di21Hc/zipjkqXH/Ya51cKR6uUdHa+4v6ClEoqXAygmfpSE2Q/UpwwWCeXGCtAKfzacbpnqdTxQqJlOWO0FBoT/rNSyr0sUT488NJNANloEPiraS2lni9U0C9Tm0eidy6ybF83dhq0xPdhH68E9+qzelXtUZDFvzMU+jS+ZKQJAzGO/WBwWrXfpQQePi0VVywUqsk= X-Microsoft-Exchange-Diagnostics: 1; DM6PR07MB4971; 6:oQqkTgZ4AJfc0aWucjeWZwAxLRG2R3bsjEDAIyfkOsUHBzAt+177jTHhJVc5hbXRW3UmDhuRlUj4hVbjPwn2ZU9n6AIsTikp6dpN1axdMO9TDNXe+fTuHZ0lW5je6QFAg9LCfFy9hViCpxhdYo9zz55rqNTbNZ9qFI/LHMTFFDXd3E2kockbSPpzMK7hpb28k9zeukn1dmvZdB61J2UCbA9GUcV8iTLT21T2uO1yAMFKnInZidtDJQw34PhUnk7V1VuGK/5et2Z+D9imGTkclJ2LIsrBAY39xvWC/XBIjVs4MNXtwKtCXXX3bZshQj2dtLFaG4Fj8fzpxl1BdJhzHnlbHpYvEZWbrCOs01W1CQT2Hu43+PIGYfmWHTJ2ZenBtC0hehm8ZFTzMYyMntFwF5xElwWbiqo2OPhYm702H3hr+pfVvVkgqchT3sP6V4te4Cp1LWhASM0gDNVXNjUn1A==; 5:G1wxhOQbZibLQAjJYI3nxvFVFkWp0RguoQQErEnNtmW1UE5lFlxXt6/KtIMhk5qKLs0Fu9NoJsCk3ZGk62NEhCTO2pbnxvB36xycaZJF4+jvKOQqsCMMeWp4qNQsTZSYrSRy//nEsgzBhwhLcfVYOmKPKQgS80m5ZHcToWpHmhk=; 7:C00s3T226huz53XnX/Yz4F4OswAny0O/79fBB0MsIcCuYQjTEwrf1hKXABIDf5lq6efcFd1Wp0YXfwjNZMrUKP9bQWM5eUbYGIFxbDY1ys+7bUykjENVmjffG1ubnwUtOLyKJ0ew98WRFJkxgZ+Qbzed6FQQvTKR9BQwydOhwJfJclatHHpA77Y7es7c0fdvbR8BzNzMULq6Z2Oo+SglvQmBhIK7YVg8a6+uoeIqpMfbADG4E1MHQ9QGco+ByeO+ SpamDiagnosticOutput: 1:99 SpamDiagnosticMetadata: NSPM X-OriginatorOrg: caviumnetworks.com X-MS-Exchange-CrossTenant-OriginalArrivalTime: 04 Sep 2018 14:13:11.0789 (UTC) X-MS-Exchange-CrossTenant-Network-Message-Id: d0e70204-2d09-4f1a-27cf-08d612708ce0 X-MS-Exchange-CrossTenant-FromEntityHeader: Hosted X-MS-Exchange-CrossTenant-Id: 711e4ccf-2e9b-4bcf-a551-4094005b6194 X-MS-Exchange-Transport-CrossTenantHeadersStamped: DM6PR07MB4971 Subject: [dpdk-dev] [PATCH v2 1/4] app/test-eventdev: fix minor typos X-BeenThere: dev@dpdk.org X-Mailman-Version: 2.1.15 Precedence: list List-Id: DPDK patches and discussions List-Unsubscribe: , List-Archive: List-Post: List-Help: List-Subscribe: , X-List-Received-Date: Tue, 04 Sep 2018 14:14:35 -0000 Fix minor typos. Fixes: 314bcf58ca8f ("app/eventdev: add pipeline queue worker functions") Signed-off-by: Pavan Nikhilesh --- 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