From mboxrd@z Thu Jan 1 00:00:00 1970 Return-Path: Received: from mails.dpdk.org (mails.dpdk.org [217.70.189.124]) by inbox.dpdk.org (Postfix) with ESMTP id 69F19457A1 for ; Mon, 12 Aug 2024 15:05:01 +0200 (CEST) Received: from mails.dpdk.org (localhost [127.0.0.1]) by mails.dpdk.org (Postfix) with ESMTP id 64CED4065A; Mon, 12 Aug 2024 15:05:01 +0200 (CEST) Received: from NAM10-DM6-obe.outbound.protection.outlook.com (mail-dm6nam10on2049.outbound.protection.outlook.com [40.107.93.49]) by mails.dpdk.org (Postfix) with ESMTP id 077E2402C3 for ; Mon, 12 Aug 2024 15:05:00 +0200 (CEST) ARC-Seal: i=1; a=rsa-sha256; s=arcselector10001; d=microsoft.com; cv=none; b=wgU8PxDchYkh+2Hh90O0JcaMO0z7t6qRrVj4LFp1HTG5VBHU/Y+I5DEAaS9VjBn2HKiW4lH6mmROinIrzkZCs/SCmtssN3wFQJf9UEnmnthtsFYsRuLQ3cYZ9cBzIGLZDZ2aRqmMNMLEmsaSgXGzuwzovZWTfNp8FjQ+3U7rVmTVDBtAUBuvsHneuC1kCg3IMZNj1W2zhSEtfbrMAJ7/wJHdErDzLR/iuMyn+iJx2Wg64OuH+PLie097RaL9Ihxq5/9tLZyFHjbdm4uM/JUvkUJQ7fBBMDOpZ/QCYhzBW87lnWffwGKBXDQU08F3m+rIoTPNxsyo7mHXig+0+M8Csw== ARC-Message-Signature: i=1; a=rsa-sha256; c=relaxed/relaxed; d=microsoft.com; s=arcselector10001; h=From:Date:Subject:Message-ID:Content-Type:MIME-Version:X-MS-Exchange-AntiSpam-MessageData-ChunkCount:X-MS-Exchange-AntiSpam-MessageData-0:X-MS-Exchange-AntiSpam-MessageData-1; bh=ms+ZuIExKY4ZyMyQJ5XgpZOSUcHQBbX5QbF9e4F0j24=; b=bJHY/qspGxKgdwqz6uJH+7uop3DdTKsBPWEtNnjP7THIIQ80stMdK1KfQGIwbMU/7BCdo2K+aGMK+YBUHxMd9/g4F+LYIC0bl9GEsuyhbVcz8zx5xxsVGA3jwFl5QI9TaTOO6ubIo9qft5PrncMrZfWm0YiXIuMggIwEuvXNgJnmiQ5sUEMFe3YAs5U/2vTj4XnXBdnSm1PB7VObqt95MNkmPMu80VI0DjCKxsVuJ2MU3TbmTTU3hT4hklmnK4AWzFUCggZ/L7PrONn6Xd5amNOYhF0B72Ly3QjMEx1/GbnPlHa2c/rzI8yUiw9Ip5b7SideYJCQn0ASWm66WPl+WA== ARC-Authentication-Results: i=1; mx.microsoft.com 1; spf=pass (sender ip is 216.228.117.160) smtp.rcpttodomain=amd.com smtp.mailfrom=nvidia.com; dmarc=pass (p=reject sp=reject pct=100) action=none header.from=nvidia.com; dkim=none (message not signed); arc=none (0) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=Nvidia.com; s=selector2; h=From:Date:Subject:Message-ID:Content-Type:MIME-Version:X-MS-Exchange-SenderADCheck; bh=ms+ZuIExKY4ZyMyQJ5XgpZOSUcHQBbX5QbF9e4F0j24=; b=r6wgruAWJlDL0xhgWZJjG864OGu4E372Qwt766Z85qHx7/9R11jzh1R4CkOVTgz3gnsJojkcffyRdXpxJF1OEOlkmYNdJBkAZ58G5nhMKic2LoyuOIhQpdZbPg58Y7Uk+ddrd1RyVblZJu00/Zmi+66c/QcbBXA7Q7RZVp4ztBOF0T6l8O+iCEYTELhSGlgfcbwAESaQG8oMOF0M7I4/Anuj5N+PA+06mRgx6/HIvCb7TM/ufK5O/09Xgdpe337+fOOJQElTfdN1yHj9VsgD5reVw5+dmNjWDLUveTpj8VtVk0x5owMVKovumBvcIwlnAp7vQzdvzws8Yld48aqEqQ== Received: from MW4PR03CA0208.namprd03.prod.outlook.com (2603:10b6:303:b8::33) by CY5PR12MB6405.namprd12.prod.outlook.com (2603:10b6:930:3e::17) with Microsoft SMTP Server (version=TLS1_2, cipher=TLS_ECDHE_RSA_WITH_AES_256_GCM_SHA384) id 15.20.7849.22; Mon, 12 Aug 2024 13:04:54 +0000 Received: from SJ5PEPF00000204.namprd05.prod.outlook.com (2603:10b6:303:b8:cafe::3e) by MW4PR03CA0208.outlook.office365.com (2603:10b6:303:b8::33) with Microsoft SMTP Server (version=TLS1_2, cipher=TLS_ECDHE_RSA_WITH_AES_256_GCM_SHA384) id 15.20.7828.33 via Frontend Transport; Mon, 12 Aug 2024 13:04:54 +0000 X-MS-Exchange-Authentication-Results: spf=pass (sender IP is 216.228.117.160) smtp.mailfrom=nvidia.com; dkim=none (message not signed) header.d=none;dmarc=pass action=none header.from=nvidia.com; Received-SPF: Pass (protection.outlook.com: domain of nvidia.com designates 216.228.117.160 as permitted sender) receiver=protection.outlook.com; client-ip=216.228.117.160; helo=mail.nvidia.com; pr=C Received: from mail.nvidia.com (216.228.117.160) by SJ5PEPF00000204.mail.protection.outlook.com (10.167.244.37) with Microsoft SMTP Server (version=TLS1_2, cipher=TLS_ECDHE_RSA_WITH_AES_256_GCM_SHA384) id 15.20.7849.8 via Frontend Transport; Mon, 12 Aug 2024 13:04:54 +0000 Received: from rnnvmail201.nvidia.com (10.129.68.8) by mail.nvidia.com (10.129.200.66) with Microsoft SMTP Server (version=TLS1_2, cipher=TLS_ECDHE_RSA_WITH_AES_256_GCM_SHA384) id 15.2.1544.4; Mon, 12 Aug 2024 06:04:39 -0700 Received: from nvidia.com (10.126.231.35) by rnnvmail201.nvidia.com (10.129.68.8) with Microsoft SMTP Server (version=TLS1_2, cipher=TLS_ECDHE_RSA_WITH_AES_256_GCM_SHA384) id 15.2.1544.4; Mon, 12 Aug 2024 06:04:37 -0700 From: Xueming Li To: Sivaprasad Tummala CC: , Konstantin Ananyev , =?UTF-8?q?Morten=20Br=C3=B8rup?= , Ferruh Yigit , dpdk stable Subject: patch 'examples: fix queue ID restriction' has been queued to stable release 23.11.2 Date: Mon, 12 Aug 2024 20:50:26 +0800 Message-ID: <20240812125035.389667-150-xuemingl@nvidia.com> X-Mailer: git-send-email 2.34.1 In-Reply-To: <20240812125035.389667-1-xuemingl@nvidia.com> References: <20240712110153.309690-23-xuemingl@nvidia.com> <20240812125035.389667-1-xuemingl@nvidia.com> MIME-Version: 1.0 Content-Type: text/plain; charset="UTF-8" Content-Transfer-Encoding: 8bit X-Originating-IP: [10.126.231.35] X-ClientProxiedBy: rnnvmail201.nvidia.com (10.129.68.8) To rnnvmail201.nvidia.com (10.129.68.8) X-EOPAttributedMessage: 0 X-MS-PublicTrafficType: Email X-MS-TrafficTypeDiagnostic: SJ5PEPF00000204:EE_|CY5PR12MB6405:EE_ X-MS-Office365-Filtering-Correlation-Id: 415240d9-240e-4219-dbbb-08dcbacf5c27 X-MS-Exchange-SenderADCheck: 1 X-MS-Exchange-AntiSpam-Relay: 0 X-Microsoft-Antispam: BCL:0; ARA:13230040|36860700013|1800799024|376014|82310400026; X-Microsoft-Antispam-Message-Info: =?utf-8?B?UHlaN284Z3dnYnd4bkZ1U1ovYUdMa3Z1UkZlN0NNaVdTQWRnOHowTE9Ob1JF?= =?utf-8?B?SktMd3JtODh3TWpNbmhRVmxTc2o4RUx5aXlRMVVrcVJmNTE0TERub1d1RHpy?= =?utf-8?B?Vy9aY0RpZll6Rkdmb2F6TGQ1OEN3UEFkSUlFaWVrR1FLSUFReFN2SkRZWE1n?= =?utf-8?B?QXl5aVlZSG9OSFdpbXJMc0Z2TER2dTV2N0hEaXdUMm8vcC9DaFAxN1RFNWZa?= =?utf-8?B?Y21hMXBaQ1NDelVOZ2g5b1Vpd0U0dWJyQnJpL09NMGh4bVpmVWRrK3ZaS0xm?= =?utf-8?B?bUwyYndqMzFoN0F3cDR5VnZlZk9iM002RVNVL3pBcmdaS3JSalFEQ3FDMncv?= =?utf-8?B?cDJkdW5pWnVMaXVkNU1mZHNTZHpDZVpJSy80Y1Nwa0w4RUVHNks4ZHZqaFBa?= =?utf-8?B?aDZPQVNNUVBUcE4zNDN3elpBYTB0cDFuL2xUNnF0ZE5UVGw0NWVDMGF0cFBM?= =?utf-8?B?WmxxWW1VU2V1SEdMOVNWMCtOT1JMakJZRmhLc2pzMjhuM0tEZlQ2M2J0VmR1?= =?utf-8?B?bUdHMVVtK2kzQlMzK0dsMVR6YWVUZk9MbDlvT2wyU3A5VEt4TklKMnN2QmFo?= =?utf-8?B?dm9saStIa3JzOTBEODVqT2dlSUpDRE9DMWJmdEZmWU0xcFVVSXNWSVlCeHhF?= =?utf-8?B?YjQyOEVFLzl0Ti9ZcDA2VjV0WVI2Z1VxSEwxdFBWZnFKQTZOOHNZalIvOXhG?= =?utf-8?B?ODZIYlNBcTgwd29palBCVHVyd2NsdkN4STUwSXZSMC9zWnQ0aFVCQlJZK0w2?= =?utf-8?B?UStyYWV4enhOem5RdjZTb1dCOTdtL0ZkSHZVa2FXem9sOG16YWRUWVJmV0Zn?= =?utf-8?B?d3ZMd085Slh1UjZiaXVFMUpZU1dpOEhUUmJyWXNJYjRlUS9oWTdTN0hDVmZr?= =?utf-8?B?S0NoRVhwdVl5WHlLVVlUUFZJMFBXK1UzOG44aDdnZ2EwQ3JyMFkyckloM0c1?= =?utf-8?B?NjVXMEtuWU5hWldsQkZNL0M4bmxqd3NtQUhPQTlBa0R1ekk2VGpScTBZbUlT?= =?utf-8?B?NGpHaU1LTjVHWFBZcjZ3OGhnZmxhRjlyK1l1aGdRU2pVUStobmpKd0sxQnVK?= =?utf-8?B?TmxEWDlwWnJpcVRkMmhhWUQxa0R6OXZlSHQzV2ZFUUN0TU4vZ3FydnJEbGhv?= =?utf-8?B?ckNwMjNqTVNlb09DTHZPbS9Ga0F6R2pLbEx4eWdNeUpubzZhNnBGS2Yzb3g4?= =?utf-8?B?OGtPaXJqYVBGK0wwQkM2R0kxblJYbnM1ODdZM3MrVVBjVVhJeU1PaUR6cTBW?= =?utf-8?B?d0dlMTA2anE4ZFR1TFZ5aVlkVDlWY21jck1sc0Q2MHZJZnl0Y0NwU0F0cHIw?= =?utf-8?B?a09iRUdNSkJtaEk3VVlxa0JTbkhVYlF0enNsUVhGWko2Tk9xM1R0QVYyT3A1?= =?utf-8?B?WHljczlvRFpwNm1yMUk3SE9YSUcybWEzcTUvaytWSVBBNzlNNDFEZzJoYUJE?= =?utf-8?B?cjVUQlVqYmVHeGpLYnN3Tmc4a2prRHpvY0xobzdUZEE1MWpER0Q1UHJBTjJa?= =?utf-8?B?WmFWZi92ZjBMOWprNG10UFQ2RlRud28rUGhoU01mVlNpeks0aEZ3djVsTm9k?= =?utf-8?B?N3M5SjRKb2dvSWMzbnZULzEwSFZOSnZNTUhIWGNLTTFmQVNrYmZDR2lRUTRa?= =?utf-8?B?ZE11b2Nqc0VrNVRYbkR5UTZlMWxRM0QxRWFGaVdiRnNlb09lczRqOFJWdWsz?= =?utf-8?B?aURBYmMyQXZUa2xsalZMd2xUL2gxTU5icVpuUkxBOWwxdHBwd2d3b0ZpVW1R?= =?utf-8?B?SUFCS2NXMXg0aSs5eUZXcmRKaXhaNFc1SVdNLzFEVW1xQ1ArNkNTQWpCRG1l?= =?utf-8?B?YUJhTkQvRE1KNFlHeXVmQy9yd3Qwc2c5ekQwTjR0K3J2c0pIR2wxa1RFOWpi?= =?utf-8?B?Q2V4clpwZHJnZmlOdXpnNHB3OUI4a0dMOWhTejJuSnRvcSsrbmRSdTBiTE1F?= =?utf-8?Q?1iRvmnBXRWRBwd8lsv7kg3GDX0PHshMx?= X-Forefront-Antispam-Report: CIP:216.228.117.160; CTRY:US; LANG:en; SCL:1; SRV:; IPV:NLI; SFV:NSPM; H:mail.nvidia.com; PTR:dc6edge1.nvidia.com; CAT:NONE; SFS:(13230040)(36860700013)(1800799024)(376014)(82310400026); DIR:OUT; SFP:1101; X-OriginatorOrg: Nvidia.com X-MS-Exchange-CrossTenant-OriginalArrivalTime: 12 Aug 2024 13:04:54.6567 (UTC) X-MS-Exchange-CrossTenant-Network-Message-Id: 415240d9-240e-4219-dbbb-08dcbacf5c27 X-MS-Exchange-CrossTenant-Id: 43083d15-7273-40c1-b7db-39efd9ccc17a X-MS-Exchange-CrossTenant-OriginalAttributedTenantConnectingIp: TenantId=43083d15-7273-40c1-b7db-39efd9ccc17a; Ip=[216.228.117.160]; Helo=[mail.nvidia.com] X-MS-Exchange-CrossTenant-AuthSource: SJ5PEPF00000204.namprd05.prod.outlook.com X-MS-Exchange-CrossTenant-AuthAs: Anonymous X-MS-Exchange-CrossTenant-FromEntityHeader: HybridOnPrem X-MS-Exchange-Transport-CrossTenantHeadersStamped: CY5PR12MB6405 X-BeenThere: stable@dpdk.org X-Mailman-Version: 2.1.29 Precedence: list List-Id: patches for DPDK stable branches List-Unsubscribe: , List-Archive: List-Post: List-Help: List-Subscribe: , Errors-To: stable-bounces@dpdk.org Hi, FYI, your patch has been queued to stable release 23.11.2 Note it hasn't been pushed to http://dpdk.org/browse/dpdk-stable yet. It will be pushed if I get no objections before 08/14/24. So please shout if anyone has objections. Also note that after the patch there's a diff of the upstream commit vs the patch applied to the branch. This will indicate if there was any rebasing needed to apply to the stable branch. If there were code changes for rebasing (ie: not only metadata diffs), please double check that the rebase was correctly done. Queued patches are on a temporary branch at: https://git.dpdk.org/dpdk-stable/log/?h=23.11-staging This queued commit can be viewed at: https://git.dpdk.org/dpdk-stable/commit/?h=23.11-staging&id=938afb0ab2bf5e34bcaa6d64e96dee3c6b8c838d Thanks. Xueming Li --- >From 938afb0ab2bf5e34bcaa6d64e96dee3c6b8c838d Mon Sep 17 00:00:00 2001 From: Sivaprasad Tummala Date: Tue, 26 Mar 2024 13:55:40 +0100 Subject: [PATCH] examples: fix queue ID restriction MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit Cc: Xueming Li [ upstream commit b23c5bd71aa5b428a404aa036b97fa7bb1a3c98a ] Currently application supports Rx queue IDs up to 255 and max queues of 256 irrespective of device support. This limits the number of active lcores to 256. The patch fixes these constraints by increasing the Rx queue IDs to support up to 65535. Fixes: af75078fece3 ("first public release") Fixes: f88e7c175a68 ("examples/l3fwd-power: add high/regular perf cores options") Fixes: 08bd1a174461 ("examples/l3fwd-graph: add graph-based l3fwd skeleton") Signed-off-by: Sivaprasad Tummala Acked-by: Konstantin Ananyev Acked-by: Morten Brørup Acked-by: Ferruh Yigit --- examples/ipsec-secgw/ipsec-secgw.c | 19 ++++++----- examples/ipsec-secgw/ipsec.h | 2 +- examples/ipsec-secgw/ipsec_worker.c | 10 +++--- examples/l3fwd-graph/main.c | 19 +++++------ examples/l3fwd-power/main.c | 49 ++++++++++++++--------------- examples/l3fwd-power/main.h | 2 +- examples/l3fwd-power/perf_core.c | 8 +++-- examples/l3fwd/l3fwd.h | 2 +- examples/l3fwd/l3fwd_acl.c | 4 +-- examples/l3fwd/l3fwd_em.c | 4 +-- examples/l3fwd/l3fwd_event.h | 2 +- examples/l3fwd/l3fwd_fib.c | 4 +-- examples/l3fwd/l3fwd_lpm.c | 5 ++- examples/l3fwd/main.c | 24 +++++++------- 14 files changed, 76 insertions(+), 78 deletions(-) diff --git a/examples/ipsec-secgw/ipsec-secgw.c b/examples/ipsec-secgw/ipsec-secgw.c index 45a303850d..782535f4b5 100644 --- a/examples/ipsec-secgw/ipsec-secgw.c +++ b/examples/ipsec-secgw/ipsec-secgw.c @@ -220,7 +220,7 @@ static const char *cfgfile; struct lcore_params { uint16_t port_id; - uint8_t queue_id; + uint16_t queue_id; uint8_t lcore_id; } __rte_cache_aligned; @@ -695,8 +695,7 @@ ipsec_poll_mode_worker(void) struct rte_mbuf *pkts[MAX_PKT_BURST]; uint32_t lcore_id; uint64_t prev_tsc, diff_tsc, cur_tsc; - uint16_t i, nb_rx, portid; - uint8_t queueid; + uint16_t i, nb_rx, portid, queueid; struct lcore_conf *qconf; int32_t rc, socket_id; const uint64_t drain_tsc = (rte_get_tsc_hz() + US_PER_S - 1) @@ -743,7 +742,7 @@ ipsec_poll_mode_worker(void) portid = rxql[i].port_id; queueid = rxql[i].queue_id; RTE_LOG(INFO, IPSEC, - " -- lcoreid=%u portid=%u rxqueueid=%hhu\n", + " -- lcoreid=%u portid=%u rxqueueid=%" PRIu16 "\n", lcore_id, portid, queueid); } @@ -788,8 +787,7 @@ int check_flow_params(uint16_t fdir_portid, uint8_t fdir_qid) { uint16_t i; - uint16_t portid; - uint8_t queueid; + uint16_t portid, queueid; for (i = 0; i < nb_lcore_params; ++i) { portid = lcore_params_array[i].port_id; @@ -851,7 +849,7 @@ check_poll_mode_params(struct eh_conf *eh_conf) return 0; } -static uint8_t +static uint16_t get_port_nb_rx_queues(const uint16_t port) { int32_t queue = -1; @@ -862,7 +860,7 @@ get_port_nb_rx_queues(const uint16_t port) lcore_params[i].queue_id > queue) queue = lcore_params[i].queue_id; } - return (uint8_t)(++queue); + return (uint16_t)(++queue); } static int32_t @@ -1050,6 +1048,7 @@ parse_config(const char *q_arg) char *str_fld[_NUM_FLD]; int32_t i; uint32_t size; + uint32_t max_fld[_NUM_FLD] = {255, RTE_MAX_QUEUES_PER_PORT, 255}; nb_lcore_params = 0; @@ -1070,7 +1069,7 @@ parse_config(const char *q_arg) for (i = 0; i < _NUM_FLD; i++) { errno = 0; int_fld[i] = strtoul(str_fld[i], &end, 0); - if (errno != 0 || end == str_fld[i] || int_fld[i] > 255) + if (errno != 0 || end == str_fld[i] || int_fld[i] > max_fld[i]) return -1; } if (nb_lcore_params >= MAX_LCORE_PARAMS) { @@ -1081,7 +1080,7 @@ parse_config(const char *q_arg) lcore_params_array[nb_lcore_params].port_id = (uint8_t)int_fld[FLD_PORT]; lcore_params_array[nb_lcore_params].queue_id = - (uint8_t)int_fld[FLD_QUEUE]; + (uint16_t)int_fld[FLD_QUEUE]; lcore_params_array[nb_lcore_params].lcore_id = (uint8_t)int_fld[FLD_LCORE]; ++nb_lcore_params; diff --git a/examples/ipsec-secgw/ipsec.h b/examples/ipsec-secgw/ipsec.h index bdcada1c40..29b9b283f0 100644 --- a/examples/ipsec-secgw/ipsec.h +++ b/examples/ipsec-secgw/ipsec.h @@ -285,7 +285,7 @@ struct cnt_blk { struct lcore_rx_queue { uint16_t port_id; - uint8_t queue_id; + uint16_t queue_id; void *sec_ctx; } __rte_cache_aligned; diff --git a/examples/ipsec-secgw/ipsec_worker.c b/examples/ipsec-secgw/ipsec_worker.c index 8d122e8519..c9c43ebd2b 100644 --- a/examples/ipsec-secgw/ipsec_worker.c +++ b/examples/ipsec-secgw/ipsec_worker.c @@ -1598,8 +1598,7 @@ ipsec_poll_mode_wrkr_inl_pr(void) int32_t socket_id; uint32_t lcore_id; int32_t i, nb_rx; - uint16_t portid; - uint8_t queueid; + uint16_t portid, queueid; prev_tsc = 0; lcore_id = rte_lcore_id(); @@ -1633,7 +1632,7 @@ ipsec_poll_mode_wrkr_inl_pr(void) portid = rxql[i].port_id; queueid = rxql[i].queue_id; RTE_LOG(INFO, IPSEC, - " -- lcoreid=%u portid=%u rxqueueid=%hhu\n", + " -- lcoreid=%u portid=%u rxqueueid=%" PRIu16 "\n", lcore_id, portid, queueid); } @@ -1729,8 +1728,7 @@ ipsec_poll_mode_wrkr_inl_pr_ss(void) uint32_t i, nb_rx, j; int32_t socket_id; uint32_t lcore_id; - uint16_t portid; - uint8_t queueid; + uint16_t portid, queueid; prev_tsc = 0; lcore_id = rte_lcore_id(); @@ -1764,7 +1762,7 @@ ipsec_poll_mode_wrkr_inl_pr_ss(void) portid = rxql[i].port_id; queueid = rxql[i].queue_id; RTE_LOG(INFO, IPSEC, - " -- lcoreid=%u portid=%u rxqueueid=%hhu\n", + " -- lcoreid=%u portid=%u rxqueueid=%" PRIu16 "\n", lcore_id, portid, queueid); } diff --git a/examples/l3fwd-graph/main.c b/examples/l3fwd-graph/main.c index 96cb1c81ff..4b018d1e78 100644 --- a/examples/l3fwd-graph/main.c +++ b/examples/l3fwd-graph/main.c @@ -90,7 +90,7 @@ static int pcap_trace_enable; struct lcore_rx_queue { uint16_t port_id; - uint8_t queue_id; + uint16_t queue_id; char node_name[RTE_NODE_NAMESIZE]; }; @@ -110,7 +110,7 @@ static struct lcore_conf lcore_conf[RTE_MAX_LCORE]; struct lcore_params { uint16_t port_id; - uint8_t queue_id; + uint16_t queue_id; uint8_t lcore_id; } __rte_cache_aligned; @@ -205,14 +205,14 @@ check_worker_model_params(void) static int check_lcore_params(void) { - uint8_t queue, lcore; + uint16_t queue, i; int socketid; - uint16_t i; + uint8_t lcore; for (i = 0; i < nb_lcore_params; ++i) { queue = lcore_params[i].queue_id; if (queue >= MAX_RX_QUEUE_PER_PORT) { - printf("Invalid queue number: %hhu\n", queue); + printf("Invalid queue number: %" PRIu16 "\n", queue); return -1; } lcore = lcore_params[i].lcore_id; @@ -257,7 +257,7 @@ check_port_config(void) return 0; } -static uint8_t +static uint16_t get_port_n_rx_queues(const uint16_t port) { int queue = -1; @@ -275,7 +275,7 @@ get_port_n_rx_queues(const uint16_t port) } } - return (uint8_t)(++queue); + return (uint16_t)(++queue); } static int @@ -450,7 +450,7 @@ parse_config(const char *q_arg) lcore_params_array[nb_lcore_params].port_id = (uint8_t)int_fld[FLD_PORT]; lcore_params_array[nb_lcore_params].queue_id = - (uint8_t)int_fld[FLD_QUEUE]; + (uint16_t)int_fld[FLD_QUEUE]; lcore_params_array[nb_lcore_params].lcore_id = (uint8_t)int_fld[FLD_LCORE]; ++nb_lcore_params; @@ -1011,7 +1011,8 @@ main(int argc, char **argv) "ethdev_tx-*", "pkt_drop", }; - uint8_t nb_rx_queue, queue, socketid; + uint8_t socketid; + uint16_t nb_rx_queue, queue; struct rte_graph_param graph_conf; struct rte_eth_dev_info dev_info; uint32_t nb_ports, nb_conf = 0; diff --git a/examples/l3fwd-power/main.c b/examples/l3fwd-power/main.c index 9c0dcd343b..5045d13533 100644 --- a/examples/l3fwd-power/main.c +++ b/examples/l3fwd-power/main.c @@ -213,7 +213,7 @@ enum freq_scale_hint_t struct lcore_rx_queue { uint16_t port_id; - uint8_t queue_id; + uint16_t queue_id; enum freq_scale_hint_t freq_up_hint; uint32_t zero_rx_packet_count; uint32_t idle_hint; @@ -837,7 +837,7 @@ sleep_until_rx_interrupt(int num, int lcore) struct rte_epoll_event event[num]; int n, i; uint16_t port_id; - uint8_t queue_id; + uint16_t queue_id; void *data; if (status[lcore].wakeup) { @@ -849,9 +849,9 @@ sleep_until_rx_interrupt(int num, int lcore) n = rte_epoll_wait(RTE_EPOLL_PER_THREAD, event, num, 10); for (i = 0; i < n; i++) { data = event[i].epdata.data; - port_id = ((uintptr_t)data) >> CHAR_BIT; + port_id = ((uintptr_t)data) >> (sizeof(uint16_t) * CHAR_BIT); queue_id = ((uintptr_t)data) & - RTE_LEN2MASK(CHAR_BIT, uint8_t); + RTE_LEN2MASK((sizeof(uint16_t) * CHAR_BIT), uint16_t); RTE_LOG(INFO, L3FWD_POWER, "lcore %u is waked up from rx interrupt on" " port %d queue %d\n", @@ -866,7 +866,7 @@ static void turn_on_off_intr(struct lcore_conf *qconf, bool on) { int i; struct lcore_rx_queue *rx_queue; - uint8_t queue_id; + uint16_t queue_id; uint16_t port_id; for (i = 0; i < qconf->n_rx_queue; ++i) { @@ -886,7 +886,7 @@ static void turn_on_off_intr(struct lcore_conf *qconf, bool on) static int event_register(struct lcore_conf *qconf) { struct lcore_rx_queue *rx_queue; - uint8_t queueid; + uint16_t queueid; uint16_t portid; uint32_t data; int ret; @@ -896,7 +896,7 @@ static int event_register(struct lcore_conf *qconf) rx_queue = &(qconf->rx_queue_list[i]); portid = rx_queue->port_id; queueid = rx_queue->queue_id; - data = portid << CHAR_BIT | queueid; + data = portid << (sizeof(uint16_t) * CHAR_BIT) | queueid; ret = rte_eth_dev_rx_intr_ctl_q(portid, queueid, RTE_EPOLL_PER_THREAD, @@ -916,8 +916,7 @@ static int main_intr_loop(__rte_unused void *dummy) unsigned int lcore_id; uint64_t prev_tsc, diff_tsc, cur_tsc; int i, j, nb_rx; - uint8_t queueid; - uint16_t portid; + uint16_t portid, queueid; struct lcore_conf *qconf; struct lcore_rx_queue *rx_queue; uint32_t lcore_rx_idle_count = 0; @@ -945,7 +944,7 @@ static int main_intr_loop(__rte_unused void *dummy) portid = qconf->rx_queue_list[i].port_id; queueid = qconf->rx_queue_list[i].queue_id; RTE_LOG(INFO, L3FWD_POWER, - " -- lcoreid=%u portid=%u rxqueueid=%hhu\n", + " -- lcoreid=%u portid=%u rxqueueid=%" PRIu16 "\n", lcore_id, portid, queueid); } @@ -1082,8 +1081,7 @@ main_telemetry_loop(__rte_unused void *dummy) unsigned int lcore_id; uint64_t prev_tsc, diff_tsc, cur_tsc, prev_tel_tsc; int i, j, nb_rx; - uint8_t queueid; - uint16_t portid; + uint16_t portid, queueid; struct lcore_conf *qconf; struct lcore_rx_queue *rx_queue; uint64_t ep_nep[2] = {0}, fp_nfp[2] = {0}; @@ -1113,7 +1111,7 @@ main_telemetry_loop(__rte_unused void *dummy) portid = qconf->rx_queue_list[i].port_id; queueid = qconf->rx_queue_list[i].queue_id; RTE_LOG(INFO, L3FWD_POWER, " -- lcoreid=%u portid=%u " - "rxqueueid=%hhu\n", lcore_id, portid, queueid); + "rxqueueid=%" PRIu16 "\n", lcore_id, portid, queueid); } while (!is_done()) { @@ -1204,8 +1202,7 @@ main_legacy_loop(__rte_unused void *dummy) uint64_t prev_tsc, diff_tsc, cur_tsc, tim_res_tsc, hz; uint64_t prev_tsc_power = 0, cur_tsc_power, diff_tsc_power; int i, j, nb_rx; - uint8_t queueid; - uint16_t portid; + uint16_t portid, queueid; struct lcore_conf *qconf; struct lcore_rx_queue *rx_queue; enum freq_scale_hint_t lcore_scaleup_hint; @@ -1233,7 +1230,7 @@ main_legacy_loop(__rte_unused void *dummy) portid = qconf->rx_queue_list[i].port_id; queueid = qconf->rx_queue_list[i].queue_id; RTE_LOG(INFO, L3FWD_POWER, " -- lcoreid=%u portid=%u " - "rxqueueid=%hhu\n", lcore_id, portid, queueid); + "rxqueueid=%" PRIu16 "\n", lcore_id, portid, queueid); } /* add into event wait list */ @@ -1398,14 +1395,14 @@ start_rx: static int check_lcore_params(void) { - uint8_t queue, lcore; - uint16_t i; + uint16_t queue, i; + uint8_t lcore; int socketid; for (i = 0; i < nb_lcore_params; ++i) { queue = lcore_params[i].queue_id; if (queue >= MAX_RX_QUEUE_PER_PORT) { - printf("invalid queue number: %hhu\n", queue); + printf("invalid queue number: %" PRIu16 "\n", queue); return -1; } lcore = lcore_params[i].lcore_id; @@ -1450,7 +1447,7 @@ check_port_config(void) return 0; } -static uint8_t +static uint16_t get_port_n_rx_queues(const uint16_t port) { int queue = -1; @@ -1461,7 +1458,7 @@ get_port_n_rx_queues(const uint16_t port) lcore_params[i].queue_id > queue) queue = lcore_params[i].queue_id; } - return (uint8_t)(++queue); + return (uint16_t)(++queue); } static int @@ -1660,6 +1657,7 @@ parse_config(const char *q_arg) char *str_fld[_NUM_FLD]; int i; unsigned size; + unsigned int max_fld[_NUM_FLD] = {255, RTE_MAX_QUEUES_PER_PORT, 255}; nb_lcore_params = 0; @@ -1679,8 +1677,7 @@ parse_config(const char *q_arg) for (i = 0; i < _NUM_FLD; i++){ errno = 0; int_fld[i] = strtoul(str_fld[i], &end, 0); - if (errno != 0 || end == str_fld[i] || int_fld[i] > - 255) + if (errno != 0 || end == str_fld[i] || int_fld[i] > max_fld[i]) return -1; } if (nb_lcore_params >= MAX_LCORE_PARAMS) { @@ -1691,7 +1688,7 @@ parse_config(const char *q_arg) lcore_params_array[nb_lcore_params].port_id = (uint8_t)int_fld[FLD_PORT]; lcore_params_array[nb_lcore_params].queue_id = - (uint8_t)int_fld[FLD_QUEUE]; + (uint16_t)int_fld[FLD_QUEUE]; lcore_params_array[nb_lcore_params].lcore_id = (uint8_t)int_fld[FLD_LCORE]; ++nb_lcore_params; @@ -2500,8 +2497,8 @@ main(int argc, char **argv) uint64_t hz; uint32_t n_tx_queue, nb_lcores; uint32_t dev_rxq_num, dev_txq_num; - uint8_t nb_rx_queue, queue, socketid; - uint16_t portid; + uint8_t socketid; + uint16_t portid, nb_rx_queue, queue; const char *ptr_strings[NUM_TELSTATS]; /* init EAL */ diff --git a/examples/l3fwd-power/main.h b/examples/l3fwd-power/main.h index 258de98f5b..40b5194726 100644 --- a/examples/l3fwd-power/main.h +++ b/examples/l3fwd-power/main.h @@ -9,7 +9,7 @@ #define MAX_LCORE_PARAMS 1024 struct lcore_params { uint16_t port_id; - uint8_t queue_id; + uint16_t queue_id; uint8_t lcore_id; } __rte_cache_aligned; diff --git a/examples/l3fwd-power/perf_core.c b/examples/l3fwd-power/perf_core.c index 41ef6d0c9a..f34442b9d0 100644 --- a/examples/l3fwd-power/perf_core.c +++ b/examples/l3fwd-power/perf_core.c @@ -22,7 +22,7 @@ static uint16_t nb_hp_lcores; struct perf_lcore_params { uint16_t port_id; - uint8_t queue_id; + uint16_t queue_id; uint8_t high_perf; uint8_t lcore_idx; } __rte_cache_aligned; @@ -132,6 +132,7 @@ parse_perf_config(const char *q_arg) char *str_fld[_NUM_FLD]; int i; unsigned int size; + unsigned int max_fld[_NUM_FLD] = {255, RTE_MAX_QUEUES_PER_PORT, 255, 255}; nb_prf_lc_prms = 0; @@ -152,7 +153,8 @@ parse_perf_config(const char *q_arg) for (i = 0; i < _NUM_FLD; i++) { errno = 0; int_fld[i] = strtoul(str_fld[i], &end, 0); - if (errno != 0 || end == str_fld[i] || int_fld[i] > 255) + if (errno != 0 || end == str_fld[i] || int_fld[i] > max_fld[i]) + return -1; } if (nb_prf_lc_prms >= MAX_LCORE_PARAMS) { @@ -163,7 +165,7 @@ parse_perf_config(const char *q_arg) prf_lc_prms[nb_prf_lc_prms].port_id = (uint8_t)int_fld[FLD_PORT]; prf_lc_prms[nb_prf_lc_prms].queue_id = - (uint8_t)int_fld[FLD_QUEUE]; + (uint16_t)int_fld[FLD_QUEUE]; prf_lc_prms[nb_prf_lc_prms].high_perf = !!(uint8_t)int_fld[FLD_LCORE_HP]; prf_lc_prms[nb_prf_lc_prms].lcore_idx = diff --git a/examples/l3fwd/l3fwd.h b/examples/l3fwd/l3fwd.h index e7ae0e5834..12c264cb4c 100644 --- a/examples/l3fwd/l3fwd.h +++ b/examples/l3fwd/l3fwd.h @@ -74,7 +74,7 @@ struct mbuf_table { struct lcore_rx_queue { uint16_t port_id; - uint8_t queue_id; + uint16_t queue_id; } __rte_cache_aligned; struct lcore_conf { diff --git a/examples/l3fwd/l3fwd_acl.c b/examples/l3fwd/l3fwd_acl.c index a1d87f4a40..31798ccb10 100644 --- a/examples/l3fwd/l3fwd_acl.c +++ b/examples/l3fwd/l3fwd_acl.c @@ -998,7 +998,7 @@ acl_main_loop(__rte_unused void *dummy) uint64_t prev_tsc, diff_tsc, cur_tsc; int i, nb_rx; uint16_t portid; - uint8_t queueid; + uint16_t queueid; struct lcore_conf *qconf; int socketid; const uint64_t drain_tsc = (rte_get_tsc_hz() + US_PER_S - 1) @@ -1021,7 +1021,7 @@ acl_main_loop(__rte_unused void *dummy) portid = qconf->rx_queue_list[i].port_id; queueid = qconf->rx_queue_list[i].queue_id; RTE_LOG(INFO, L3FWD, - " -- lcoreid=%u portid=%u rxqueueid=%hhu\n", + " -- lcoreid=%u portid=%u rxqueueid=%" PRIu16 "\n", lcore_id, portid, queueid); } diff --git a/examples/l3fwd/l3fwd_em.c b/examples/l3fwd/l3fwd_em.c index 40e102b38a..f18ac0048b 100644 --- a/examples/l3fwd/l3fwd_em.c +++ b/examples/l3fwd/l3fwd_em.c @@ -586,7 +586,7 @@ em_main_loop(__rte_unused void *dummy) unsigned lcore_id; uint64_t prev_tsc, diff_tsc, cur_tsc; int i, nb_rx; - uint8_t queueid; + uint16_t queueid; uint16_t portid; struct lcore_conf *qconf; const uint64_t drain_tsc = (rte_get_tsc_hz() + US_PER_S - 1) / @@ -609,7 +609,7 @@ em_main_loop(__rte_unused void *dummy) portid = qconf->rx_queue_list[i].port_id; queueid = qconf->rx_queue_list[i].queue_id; RTE_LOG(INFO, L3FWD, - " -- lcoreid=%u portid=%u rxqueueid=%hhu\n", + " -- lcoreid=%u portid=%u rxqueueid=%" PRIu16 "\n", lcore_id, portid, queueid); } diff --git a/examples/l3fwd/l3fwd_event.h b/examples/l3fwd/l3fwd_event.h index 9aad358003..c6a4a89127 100644 --- a/examples/l3fwd/l3fwd_event.h +++ b/examples/l3fwd/l3fwd_event.h @@ -78,8 +78,8 @@ struct l3fwd_event_resources { uint8_t deq_depth; uint8_t has_burst; uint8_t enabled; - uint8_t eth_rx_queues; uint8_t vector_enabled; + uint16_t eth_rx_queues; uint16_t vector_size; uint64_t vector_tmo_ns; }; diff --git a/examples/l3fwd/l3fwd_fib.c b/examples/l3fwd/l3fwd_fib.c index 6a21984415..f38b19af3f 100644 --- a/examples/l3fwd/l3fwd_fib.c +++ b/examples/l3fwd/l3fwd_fib.c @@ -186,7 +186,7 @@ fib_main_loop(__rte_unused void *dummy) uint64_t prev_tsc, diff_tsc, cur_tsc; int i, nb_rx; uint16_t portid; - uint8_t queueid; + uint16_t queueid; struct lcore_conf *qconf; const uint64_t drain_tsc = (rte_get_tsc_hz() + US_PER_S - 1) / US_PER_S * BURST_TX_DRAIN_US; @@ -208,7 +208,7 @@ fib_main_loop(__rte_unused void *dummy) portid = qconf->rx_queue_list[i].port_id; queueid = qconf->rx_queue_list[i].queue_id; RTE_LOG(INFO, L3FWD, - " -- lcoreid=%u portid=%u rxqueueid=%hhu\n", + " -- lcoreid=%u portid=%u rxqueueid=%" PRIu16 "\n", lcore_id, portid, queueid); } diff --git a/examples/l3fwd/l3fwd_lpm.c b/examples/l3fwd/l3fwd_lpm.c index a484a33089..e8fd95aae9 100644 --- a/examples/l3fwd/l3fwd_lpm.c +++ b/examples/l3fwd/l3fwd_lpm.c @@ -148,8 +148,7 @@ lpm_main_loop(__rte_unused void *dummy) unsigned lcore_id; uint64_t prev_tsc, diff_tsc, cur_tsc; int i, nb_rx; - uint16_t portid; - uint8_t queueid; + uint16_t portid, queueid; struct lcore_conf *qconf; const uint64_t drain_tsc = (rte_get_tsc_hz() + US_PER_S - 1) / US_PER_S * BURST_TX_DRAIN_US; @@ -171,7 +170,7 @@ lpm_main_loop(__rte_unused void *dummy) portid = qconf->rx_queue_list[i].port_id; queueid = qconf->rx_queue_list[i].queue_id; RTE_LOG(INFO, L3FWD, - " -- lcoreid=%u portid=%u rxqueueid=%hhu\n", + " -- lcoreid=%u portid=%u rxqueueid=%" PRIu16 "\n", lcore_id, portid, queueid); } diff --git a/examples/l3fwd/main.c b/examples/l3fwd/main.c index 8d32ae1dd5..039207b06c 100644 --- a/examples/l3fwd/main.c +++ b/examples/l3fwd/main.c @@ -98,7 +98,7 @@ struct parm_cfg parm_config; struct lcore_params { uint16_t port_id; - uint8_t queue_id; + uint16_t queue_id; uint8_t lcore_id; } __rte_cache_aligned; @@ -292,14 +292,14 @@ setup_l3fwd_lookup_tables(void) static int check_lcore_params(void) { - uint8_t queue, lcore; - uint16_t i; + uint16_t queue, i; + uint8_t lcore; int socketid; for (i = 0; i < nb_lcore_params; ++i) { queue = lcore_params[i].queue_id; if (queue >= MAX_RX_QUEUE_PER_PORT) { - printf("invalid queue number: %hhu\n", queue); + printf("invalid queue number: %" PRIu16 "\n", queue); return -1; } lcore = lcore_params[i].lcore_id; @@ -336,7 +336,7 @@ check_port_config(void) return 0; } -static uint8_t +static uint16_t get_port_n_rx_queues(const uint16_t port) { int queue = -1; @@ -352,7 +352,7 @@ get_port_n_rx_queues(const uint16_t port) lcore_params[i].port_id); } } - return (uint8_t)(++queue); + return (uint16_t)(++queue); } static int @@ -500,6 +500,7 @@ parse_config(const char *q_arg) char *str_fld[_NUM_FLD]; int i; unsigned size; + uint16_t max_fld[_NUM_FLD] = {255, RTE_MAX_QUEUES_PER_PORT, 255}; nb_lcore_params = 0; @@ -518,7 +519,7 @@ parse_config(const char *q_arg) for (i = 0; i < _NUM_FLD; i++){ errno = 0; int_fld[i] = strtoul(str_fld[i], &end, 0); - if (errno != 0 || end == str_fld[i] || int_fld[i] > 255) + if (errno != 0 || end == str_fld[i] || int_fld[i] > max_fld[i]) return -1; } if (nb_lcore_params >= MAX_LCORE_PARAMS) { @@ -529,7 +530,7 @@ parse_config(const char *q_arg) lcore_params_array[nb_lcore_params].port_id = (uint8_t)int_fld[FLD_PORT]; lcore_params_array[nb_lcore_params].queue_id = - (uint8_t)int_fld[FLD_QUEUE]; + (uint16_t)int_fld[FLD_QUEUE]; lcore_params_array[nb_lcore_params].lcore_id = (uint8_t)int_fld[FLD_LCORE]; ++nb_lcore_params; @@ -630,7 +631,7 @@ parse_event_eth_rx_queues(const char *eth_rx_queues) { struct l3fwd_event_resources *evt_rsrc = l3fwd_get_eventdev_rsrc(); char *end = NULL; - uint8_t num_eth_rx_queues; + uint16_t num_eth_rx_queues; /* parse decimal string */ num_eth_rx_queues = strtoul(eth_rx_queues, &end, 10); @@ -1211,7 +1212,8 @@ config_port_max_pkt_len(struct rte_eth_conf *conf, static void l3fwd_poll_resource_setup(void) { - uint8_t nb_rx_queue, queue, socketid; + uint8_t socketid; + uint16_t nb_rx_queue, queue; struct rte_eth_dev_info dev_info; uint32_t n_tx_queue, nb_lcores; struct rte_eth_txconf *txconf; @@ -1535,7 +1537,7 @@ main(int argc, char **argv) struct lcore_conf *qconf; uint16_t queueid, portid; unsigned int lcore_id; - uint8_t queue; + uint16_t queue; int ret; /* init EAL */ -- 2.34.1 --- Diff of the applied patch vs upstream commit (please double-check if non-empty: --- --- - 2024-08-12 20:44:07.199836826 +0800 +++ 0149-examples-fix-queue-ID-restriction.patch 2024-08-12 20:44:02.585069391 +0800 @@ -1 +1 @@ -From b23c5bd71aa5b428a404aa036b97fa7bb1a3c98a Mon Sep 17 00:00:00 2001 +From 938afb0ab2bf5e34bcaa6d64e96dee3c6b8c838d Mon Sep 17 00:00:00 2001 @@ -7,0 +8,3 @@ +Cc: Xueming Li + +[ upstream commit b23c5bd71aa5b428a404aa036b97fa7bb1a3c98a ] @@ -19 +21,0 @@ -Cc: stable@dpdk.org @@ -43 +45 @@ -index d7c18bea34..8292a262cd 100644 +index 45a303850d..782535f4b5 100644 @@ -48 +50 @@ - struct __rte_cache_aligned lcore_params { + struct lcore_params { @@ -53 +55 @@ - }; + } __rte_cache_aligned; @@ -129 +131 @@ -index 36b6164ab2..6f45fdb166 100644 +index bdcada1c40..29b9b283f0 100644 @@ -134 +136 @@ - struct __rte_cache_aligned lcore_rx_queue { + struct lcore_rx_queue { @@ -139 +141 @@ - }; + } __rte_cache_aligned; @@ -184 +186 @@ -index ec4d8c94c5..0866822e93 100644 +index 96cb1c81ff..4b018d1e78 100644 @@ -198 +200 @@ - struct __rte_cache_aligned lcore_params { + struct lcore_params { @@ -203 +205 @@ - }; + } __rte_cache_aligned; @@ -261 +263 @@ -index fba11da7ca..74e906cb5d 100644 +index 9c0dcd343b..5045d13533 100644 @@ -264 +266 @@ -@@ -214,7 +214,7 @@ enum freq_scale_hint_t +@@ -213,7 +213,7 @@ enum freq_scale_hint_t @@ -266 +268 @@ - struct __rte_cache_aligned lcore_rx_queue { + struct lcore_rx_queue { @@ -273 +275 @@ -@@ -838,7 +838,7 @@ sleep_until_rx_interrupt(int num, int lcore) +@@ -837,7 +837,7 @@ sleep_until_rx_interrupt(int num, int lcore) @@ -282 +284 @@ -@@ -850,9 +850,9 @@ sleep_until_rx_interrupt(int num, int lcore) +@@ -849,9 +849,9 @@ sleep_until_rx_interrupt(int num, int lcore) @@ -294 +296 @@ -@@ -867,7 +867,7 @@ static void turn_on_off_intr(struct lcore_conf *qconf, bool on) +@@ -866,7 +866,7 @@ static void turn_on_off_intr(struct lcore_conf *qconf, bool on) @@ -303 +305 @@ -@@ -887,7 +887,7 @@ static void turn_on_off_intr(struct lcore_conf *qconf, bool on) +@@ -886,7 +886,7 @@ static void turn_on_off_intr(struct lcore_conf *qconf, bool on) @@ -312 +314 @@ -@@ -897,7 +897,7 @@ static int event_register(struct lcore_conf *qconf) +@@ -896,7 +896,7 @@ static int event_register(struct lcore_conf *qconf) @@ -321 +323 @@ -@@ -917,8 +917,7 @@ static int main_intr_loop(__rte_unused void *dummy) +@@ -916,8 +916,7 @@ static int main_intr_loop(__rte_unused void *dummy) @@ -331 +333 @@ -@@ -946,7 +945,7 @@ static int main_intr_loop(__rte_unused void *dummy) +@@ -945,7 +944,7 @@ static int main_intr_loop(__rte_unused void *dummy) @@ -340 +342 @@ -@@ -1083,8 +1082,7 @@ main_telemetry_loop(__rte_unused void *dummy) +@@ -1082,8 +1081,7 @@ main_telemetry_loop(__rte_unused void *dummy) @@ -350 +352 @@ -@@ -1114,7 +1112,7 @@ main_telemetry_loop(__rte_unused void *dummy) +@@ -1113,7 +1111,7 @@ main_telemetry_loop(__rte_unused void *dummy) @@ -359 +361 @@ -@@ -1205,8 +1203,7 @@ main_legacy_loop(__rte_unused void *dummy) +@@ -1204,8 +1202,7 @@ main_legacy_loop(__rte_unused void *dummy) @@ -369 +371 @@ -@@ -1234,7 +1231,7 @@ main_legacy_loop(__rte_unused void *dummy) +@@ -1233,7 +1230,7 @@ main_legacy_loop(__rte_unused void *dummy) @@ -378 +380 @@ -@@ -1399,14 +1396,14 @@ start_rx: +@@ -1398,14 +1395,14 @@ start_rx: @@ -396 +398 @@ -@@ -1451,7 +1448,7 @@ check_port_config(void) +@@ -1450,7 +1447,7 @@ check_port_config(void) @@ -405 +407 @@ -@@ -1462,7 +1459,7 @@ get_port_n_rx_queues(const uint16_t port) +@@ -1461,7 +1458,7 @@ get_port_n_rx_queues(const uint16_t port) @@ -414 +416 @@ -@@ -1661,6 +1658,7 @@ parse_config(const char *q_arg) +@@ -1660,6 +1657,7 @@ parse_config(const char *q_arg) @@ -422 +424 @@ -@@ -1680,8 +1678,7 @@ parse_config(const char *q_arg) +@@ -1679,8 +1677,7 @@ parse_config(const char *q_arg) @@ -432 +434 @@ -@@ -1692,7 +1689,7 @@ parse_config(const char *q_arg) +@@ -1691,7 +1688,7 @@ parse_config(const char *q_arg) @@ -441 +443 @@ -@@ -2501,8 +2498,8 @@ main(int argc, char **argv) +@@ -2500,8 +2497,8 @@ main(int argc, char **argv) @@ -453 +455 @@ -index e85e14bd9d..378f54794c 100644 +index 258de98f5b..40b5194726 100644 @@ -458 +460 @@ - struct __rte_cache_aligned lcore_params { + struct lcore_params { @@ -463 +465 @@ - }; + } __rte_cache_aligned; @@ -466 +468 @@ -index c8fc69e6d3..77248889c0 100644 +index 41ef6d0c9a..f34442b9d0 100644 @@ -471 +473 @@ - struct __rte_cache_aligned perf_lcore_params { + struct perf_lcore_params { @@ -477 +479 @@ - }; + } __rte_cache_aligned; @@ -506 +508 @@ -index f51da43319..93ce652d02 100644 +index e7ae0e5834..12c264cb4c 100644 @@ -511 +513 @@ - struct __rte_cache_aligned lcore_rx_queue { + struct lcore_rx_queue { @@ -515 +517 @@ - }; + } __rte_cache_aligned; @@ -517 +519 @@ - struct __rte_cache_aligned lcore_conf { + struct lcore_conf { @@ -519 +521 @@ -index 2109ab0a8c..b635011ef7 100644 +index a1d87f4a40..31798ccb10 100644 @@ -522 +524 @@ -@@ -1061,7 +1061,7 @@ acl_main_loop(__rte_unused void *dummy) +@@ -998,7 +998,7 @@ acl_main_loop(__rte_unused void *dummy) @@ -531 +533 @@ -@@ -1084,7 +1084,7 @@ acl_main_loop(__rte_unused void *dummy) +@@ -1021,7 +1021,7 @@ acl_main_loop(__rte_unused void *dummy) @@ -541 +543 @@ -index d98e66ea2c..31a7e05e39 100644 +index 40e102b38a..f18ac0048b 100644 @@ -622 +624 @@ -index ad28ba9d2e..f5f5f1a7fb 100644 +index 8d32ae1dd5..039207b06c 100644 @@ -627 +629 @@ - struct __rte_cache_aligned lcore_params { + struct lcore_params { @@ -632 +634 @@ - }; + } __rte_cache_aligned;