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 E13D9A04A7; Mon, 24 Jan 2022 13:35:50 +0100 (CET) Received: from [217.70.189.124] (localhost [127.0.0.1]) by mails.dpdk.org (Postfix) with ESMTP id B03ED4111B; Mon, 24 Jan 2022 13:35:50 +0100 (CET) Received: from mga07.intel.com (mga07.intel.com [134.134.136.100]) by mails.dpdk.org (Postfix) with ESMTP id AF40340E0F; Mon, 24 Jan 2022 13:35:46 +0100 (CET) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/simple; d=intel.com; i=@intel.com; q=dns/txt; s=Intel; t=1643027747; x=1674563747; h=message-id:date:to:cc:references:from:subject: in-reply-to:content-transfer-encoding:mime-version; bh=ZsmGYWVTvQXZE9uWpsN6K8YQlZMm10MIOiL4ZGOesxI=; b=Aakr/k9KpQiohH/Pyrbc7sqPee0vf25lrtFySr7e5ZnQXxxob6nk3BLa SQb4IBc1QtTxIhmI/h/gEt9i71xG65xP/XhxtxKr/E8hb1FxzL+Boen9S rmWrsfH0Y7eljUwYgNfYZ02kjn5kQSEFWxNMMoFt0kmexPjpfx/sH1Dv3 qmEaFwlGa1qaaHcuwAYMvMw2old2ogx/7lJ8Qbm+TQCur2lh7l6QKvhnN TOtqjx+PlUuN4WInpXfKzHvMKd8NWfP7jtcEVQ1I3E11ZWPq3RuD2t1HH VbOxWhIwLvDHt0/Rm32jRovfVmDDGkLxG6W4T7u1nCB++j/hAGbyrUwy5 A==; X-IronPort-AV: E=McAfee;i="6200,9189,10236"; a="309354331" X-IronPort-AV: E=Sophos;i="5.88,311,1635231600"; d="scan'208";a="309354331" Received: from orsmga002.jf.intel.com ([10.7.209.21]) by orsmga105.jf.intel.com with ESMTP/TLS/ECDHE-RSA-AES256-GCM-SHA384; 24 Jan 2022 04:35:14 -0800 X-ExtLoop1: 1 X-IronPort-AV: E=Sophos;i="5.88,311,1635231600"; d="scan'208";a="494604809" Received: from orsmsx606.amr.corp.intel.com ([10.22.229.19]) by orsmga002.jf.intel.com with ESMTP; 24 Jan 2022 04:35:13 -0800 Received: from orsmsx607.amr.corp.intel.com (10.22.229.20) by ORSMSX606.amr.corp.intel.com (10.22.229.19) with Microsoft SMTP Server (version=TLS1_2, cipher=TLS_ECDHE_RSA_WITH_AES_128_GCM_SHA256) id 15.1.2308.20; Mon, 24 Jan 2022 04:35:13 -0800 Received: from ORSEDG602.ED.cps.intel.com (10.7.248.7) by orsmsx607.amr.corp.intel.com (10.22.229.20) with Microsoft SMTP Server (version=TLS1_2, cipher=TLS_ECDHE_RSA_WITH_AES_128_GCM_SHA256) id 15.1.2308.20 via Frontend Transport; Mon, 24 Jan 2022 04:35:13 -0800 Received: from NAM11-BN8-obe.outbound.protection.outlook.com (104.47.58.171) by edgegateway.intel.com (134.134.137.103) with Microsoft SMTP Server (version=TLS1_2, cipher=TLS_ECDHE_RSA_WITH_AES_256_GCM_SHA384) id 15.1.2308.20; Mon, 24 Jan 2022 04:35:12 -0800 ARC-Seal: i=1; a=rsa-sha256; s=arcselector9901; d=microsoft.com; cv=none; b=GjYUnwv0zjCNnJbq76JQz4d1xrTuyIRLix7SCCX+80xcKGNjTG2Y01aXg35NLAKEcVwNqLdSAj4URpYJrYHvfbGWZ7BhOZ7Mi1Qetol53FfpJQ2r5Qtb/veyrDbEs5/8loaxz8/5LyBe5juZSTPhFk6en0DpBC6NKNH5BPGcoVPzp29cd5VZHLDnusepdsyse6RkFUa2TdTuXqYrQh55mMM739BOCLfKZX7EMTWFsjP4zxq8YKOZqftgpTDqIYbZyM9nzzNCOKAjogze1kOBJOt/BPSJSBoAZHYU1tKLmDHHhCVPnO6aLLlmnFcMURo6xGkVv8lZS+/zacs5C9/UQg== ARC-Message-Signature: i=1; a=rsa-sha256; c=relaxed/relaxed; d=microsoft.com; s=arcselector9901; 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=hxUEZTEsOZTgscskylf3Yc1QIDL7wAFuNqaftii/5LE=; b=K+6BWa6rWexF+gPAoG/g2PB1q9T9oLU2R/bcIwE0jbaIBQhYkuhjduym4JW/fPkygDfS7bSmFKGH5XwcDuAUdXDDA7wXN/OTeysWWUXiBL7yNwnC8jmORYCQkroC69yFnXLDI3eSTbnGohlepq7hoVWzzisp69KQxdfNdCS4Nywvclvs8Zztno+Hso5XVZmda5YRrOjn+/7kO8aIQ1byIhJleHWeWsTVPHz86F3kL/IBxLf2MhV5VPCDsjYClkK0Pgdx0bwpf6J5y9LDAcJaCT9xj6LRE4TOSKs5eAOST0JD1OQYDwAjiFWfSwWYQA1fNrahtFoSZu4TNphaRlcGaA== ARC-Authentication-Results: i=1; mx.microsoft.com 1; spf=none; dmarc=none; dkim=none; arc=none Authentication-Results: dkim=none (message not signed) header.d=none;dmarc=none action=none header.from=intel.com; Received: from PH0PR11MB5000.namprd11.prod.outlook.com (2603:10b6:510:41::19) by DM6PR11MB3756.namprd11.prod.outlook.com (2603:10b6:5:136::10) with Microsoft SMTP Server (version=TLS1_2, cipher=TLS_ECDHE_RSA_WITH_AES_256_GCM_SHA384) id 15.20.4909.12; Mon, 24 Jan 2022 12:35:10 +0000 Received: from PH0PR11MB5000.namprd11.prod.outlook.com ([fe80::5046:8550:928d:850e]) by PH0PR11MB5000.namprd11.prod.outlook.com ([fe80::5046:8550:928d:850e%7]) with mapi id 15.20.4909.017; Mon, 24 Jan 2022 12:35:10 +0000 Message-ID: Date: Mon, 24 Jan 2022 12:35:05 +0000 Content-Language: en-US To: Kumara Parameshwaran , CC: Kumara Parameshwaran , References: <20220121042944.23929-1-kumaraparamesh92@gmail.com> <20220124121251.64762-1-kumaraparamesh92@gmail.com> From: Ferruh Yigit Subject: Re: [PATCH v2] net/tap: fix to populate fds in secondary process X-User: ferruhy In-Reply-To: <20220124121251.64762-1-kumaraparamesh92@gmail.com> Content-Type: text/plain; charset="UTF-8"; format=flowed Content-Transfer-Encoding: 7bit X-ClientProxiedBy: LNXP265CA0062.GBRP265.PROD.OUTLOOK.COM (2603:10a6:600:5d::26) To PH0PR11MB5000.namprd11.prod.outlook.com (2603:10b6:510:41::19) MIME-Version: 1.0 X-MS-PublicTrafficType: Email X-MS-Office365-Filtering-Correlation-Id: be591b50-558e-4396-eed6-08d9df35f60f X-MS-TrafficTypeDiagnostic: DM6PR11MB3756:EE_ X-Microsoft-Antispam-PRVS: X-MS-Oob-TLC-OOBClassifiers: OLM:2201; X-MS-Exchange-SenderADCheck: 1 X-MS-Exchange-AntiSpam-Relay: 0 X-Microsoft-Antispam: BCL:0; X-Microsoft-Antispam-Message-Info: NykpBq26Z9YDnshdkJXbO3ZaaI9Tdl8SfDm1V8q9p9cWH9jWRv0DN1lu83aKlGlhVW0MJsI7R5SRlC1w20MeQipMqcPU+YyprK2ku80OD8cdLyLMMst0RVAmYTDp3ijLUp6kLonvceKnuO2qhRLP8Oilpw6josJZJz23jlchqzn93uCQBA8/yOJZekKHHIQPy5bYHSSHMX48Zr/fAhdikHjFo/C96uk6PO7lm7ymjqQCshPChawLpdOzw/GvU/gNe3xGK7lKL0/Z477OF4jictObvqKQr3/4QcoDsM/WMkIhmFgSVjYdJz1TfMh71MoGaP0POS8869WYbRtbOYUgC+eOL0aPg5Njuy4VYQQYwcPF7TMWuFPuycJ6YdiXlcbI6Hy1oh4V0hQB7YmOVEOYYrndYGhkT6e3cy4+bxOJVdTJAbhDa98hHwt0UL0b3462F+6vumDSOtqzJheCJJE3XEB9f28Q323pCS+ofiRio4S+/d6DA0MCFf2vybrnPWXbW/+0WjpPGhH3To36U2MLZQrOmpKemGFIJHsNv2gVl3h0fauWeQIFW20cXI8/DTH3iE4SJ8QqcLhe0mbte/cnA8tejS3Jq9u2MR2aTMvsOt7l/5AhCx9Y0ARAJBe8y3yhuIyKb3I+vVQ3ipNDB6qPL8T+bFh+93+EmCz7UlCa8Bt/5E0H6SHBeeDwfaLFDfU6EObxVTZ4Xu4gh90n0X6+hg== X-Forefront-Antispam-Report: CIP:255.255.255.255; CTRY:; LANG:en; SCL:1; SRV:; IPV:NLI; SFV:NSPM; H:PH0PR11MB5000.namprd11.prod.outlook.com; PTR:; CAT:NONE; SFS:(366004)(6506007)(66556008)(8936002)(31686004)(6666004)(8676002)(4326008)(82960400001)(66476007)(316002)(6486002)(36756003)(30864003)(6512007)(2906002)(5660300002)(26005)(186003)(508600001)(66946007)(31696002)(44832011)(53546011)(86362001)(83380400001)(38100700002)(2616005)(45980500001); DIR:OUT; SFP:1102; X-MS-Exchange-AntiSpam-MessageData-ChunkCount: 1 X-MS-Exchange-AntiSpam-MessageData-0: =?utf-8?B?RlF1b0NPSU1tQWRYRFYyNlVuM0VneVZieDFIRFczNVZJL1o1bHc1b28wbEhF?= =?utf-8?B?QVQ1UGxRbkw0bUtUcVhuWjUwOHh0VmZPK3I2Ry9COFM4eTdoRWkrMWhtYklQ?= =?utf-8?B?dmxIb0x4WnJacm44UXBBa3I3L2RSQ1NJdE9NeUU3RXpBZHJyNUttbndRakk0?= =?utf-8?B?SU8rSDZSTXp3NTZpWDF1b09lS0wwalExbTlUV3N4OUlHeDNRZzBwTUo2aURy?= =?utf-8?B?WFhWZkJIczl0bUVKZytldk93OTlBbE5TbTVtR1Y0R3o4TWRaNGQ2U2s4VFk2?= =?utf-8?B?aENZcDYwbFVINlFiaCtFelcyTmNEN013L0dLMG1GK29iNHNPRkpZVXlrMHZE?= =?utf-8?B?N0NmdVhSeHc1eUtVWjdWQUdXdmxGeXR0bGUvTjROdmFjMXd0SlVmRUN3ampu?= =?utf-8?B?N0NGaTBmdUVsa2JGZkpvc1lKbzJQbTJlUXAvNUtWODJzYVpBeklCMUdFMWZo?= =?utf-8?B?RExtUmFWZ1YwS01haTJUSW45QjBOWjZ3RjU0ZGo1L1RlM015OHhsNjFlanRC?= =?utf-8?B?VHk2TDk0VU8xWXBDNkZ3b3g1MEhSUkxiYWtvSlpKc0I0cUVtRkNqM0htVXZI?= =?utf-8?B?b1dtbmVhRzdKTEVvbXNmYzNtdG50TlhaL25MKytHU3ZQODBkL3VhK2tQOGZs?= =?utf-8?B?YmVwV3g4eDVCVEoxN2ErVmhCVVQ2ZGc4QVdJWFV5NVovUU5UOGhaVklXVjZJ?= =?utf-8?B?RFV1YStuekV5NnNkTHVuUUh0dENPc0hTY0ZmYXZONFIrNHlNWFBGUzZxTXNG?= =?utf-8?B?dHQ0RlZjR3c1QWt3cDNWdkpCS252ekdHRCtoVjU2QXI4Qm9Ub2xUYmJsOXRw?= =?utf-8?B?NVlnQ3h1bHJKRjZSUVIxQWdsQmcrS3d6Tm9GSlVSTHhwVU81Z2QvaldqNENy?= =?utf-8?B?bUFBUVJOaWZMUTJWUm9pRTdiVXZYYXZiamNpNFFtYWNWZStjRk90K3k4K0tF?= =?utf-8?B?Wi9Pb0Z6MkVHN1lLWEhNQnBza0sxTURnc3RYRTBpU2tKVzA1WlFURWxIcWh4?= =?utf-8?B?TnkwY3dPcUV2Q2hHOCtaTWZLSjlldlFMWUc5VUd2aUhxN0VUaTMwazAxUUZ2?= =?utf-8?B?bUpVUEtlWmtpZERFb0l2d2FmS091Wkp1ajEzNHJvcGx3emZkeEloMjNIN05U?= =?utf-8?B?TWhPckJ3QVRtUG0wdUFkcVFjY1RCcy9mVWJ6aWdxSUhCK0NjQ2s3K3VIOTVm?= =?utf-8?B?TkluYm03aHRXcWVtdE1SYWlDWUtuM0JYdTF2SG5UZ3Z3b1UyV1dRWDduaDJp?= =?utf-8?B?UE1vWUtUTFY0dWtVZ3VTRlZ5RzZ4bUxuRktrVzkzSGt5ZlN4UGE0SVZmTis0?= =?utf-8?B?ajl4cnhCMERvQ2hTVzZZQ3Fia0lWQmtQWFhZSzFZNDlxUnYySTZrcncrd2li?= =?utf-8?B?TEFZMGptSG9xVnlTcWQrS0FzeTFrQTN5MmZNYXgwSXAweHJJdzVDRWZxVzlG?= =?utf-8?B?YWQyWlh2MWplTlBESTF1aFBnN3pESUpZZGxFeENnVlFrMDhYSVJzVEF0U1BI?= =?utf-8?B?dFFlbXkzc0xOUzNXalJPdk9EZXdMQko4YkkxUzk3WTZlZDE5T1RoWEtTWm0y?= =?utf-8?B?cTBsQVptaHBWVVBvYm5vZThnczFNU1ROL2JSeFM5OFZzL1pTMUlNcmxnOFVG?= =?utf-8?B?QXl4cmhDRGdXK0tISEhXeEsrUlZmalZVUlFpditUcEVhdGtqVzZWL0dwQzhm?= =?utf-8?B?SVU0aUtxeHVtOWVUdi9VanM2Z01aMnB6aXF0RzVwT1hKbytqNU41MmtuYS9n?= =?utf-8?B?NG5wbWlqS1BYMXpJNUxsZWFCWko5WmQ5TnBzMExVem4xK1hRenFjRnFSL1Zl?= =?utf-8?B?T3VwMGNXdVlCa2Z0alpFcjFqQm8zQkRGdmlTVzRFMnRXZ3FXcGZzNlJVUlBX?= =?utf-8?B?WktZRWhhdVR0RUNPNTU3UHFMMHMxbG5YOVg5UnRZZmk4bklCNW5YaURpSzFi?= =?utf-8?B?VEM3ZjRPemRucXBCZ0lHbG12TUgyT1hNVFNod3VJYTRNZGJRMkVkZVZ4Y1Z6?= =?utf-8?B?QTJDd3F2d1NQZFpGa1RkOFhqYkZ0am5vWEFhcDE0d0czNjlyNHA3ckZKVGdO?= =?utf-8?B?VmhmRXhaUzBNajdjUUdaRmhGVWdLL2JSZGk1Q1MvSXRiOFZuVy9xYWIyeUkx?= =?utf-8?B?ckVuVGZ3QlFLRHJjVU9rTEcxRFJ3c1NCWnM4cjNvUm1BUHJTLzlteGNxczNJ?= =?utf-8?Q?8OL1BQsbvJvJyyzC0/8BjLs=3D?= X-MS-Exchange-CrossTenant-Network-Message-Id: be591b50-558e-4396-eed6-08d9df35f60f X-MS-Exchange-CrossTenant-AuthSource: PH0PR11MB5000.namprd11.prod.outlook.com X-MS-Exchange-CrossTenant-AuthAs: Internal X-MS-Exchange-CrossTenant-OriginalArrivalTime: 24 Jan 2022 12:35:10.6947 (UTC) X-MS-Exchange-CrossTenant-FromEntityHeader: Hosted X-MS-Exchange-CrossTenant-Id: 46c98d88-e344-4ed4-8496-4ed7712e255d X-MS-Exchange-CrossTenant-MailboxType: HOSTED X-MS-Exchange-CrossTenant-UserPrincipalName: y63dbJD5TZQfU8lqa8YXPqCKjeWHrm/9M3oioWxg0+RkJYsLrmhPydWRSqLv1W5zMsRzfpN2Wi45V+NdqHf3Sw== X-MS-Exchange-Transport-CrossTenantHeadersStamped: DM6PR11MB3756 X-OriginatorOrg: intel.com X-BeenThere: dev@dpdk.org X-Mailman-Version: 2.1.29 Precedence: list List-Id: DPDK patches and discussions List-Unsubscribe: , List-Archive: List-Post: List-Help: List-Subscribe: , Errors-To: dev-bounces@dpdk.org On 1/24/2022 12:12 PM, Kumara Parameshwaran wrote: > From: Kumara Parameshwaran > > When a tap device is hotplugged to primary process which in turn > adds the device to all secondary process, the secondary process > does a tap_mp_attach_queues, but the fds are not populated in > the primary during the probe they are populated during the queue_setup, > added a fix to sync the queues during rte_eth_dev_start > > Fixes: 4852aa8f6e21 ("drivers/net: enable hotplug on secondary process") > Cc: stable@dpdk.org > > Signed-off-by: Kumara Parameshwaran > --- > > v2: > * Addressed review comments to move the function declaration and version > map > Thanks for adding patch version. > drivers/net/tap/rte_eth_tap.c | 196 +++++++++++++--------------------- > lib/ethdev/ethdev_driver.h | 17 +++ > lib/ethdev/rte_ethdev.c | 11 ++ > lib/ethdev/version.map | 2 + > 4 files changed, 102 insertions(+), 124 deletions(-) > Can you please separate etdev (API) changes to another patch, so this will be a patchset with two patches, first patch adds ethdev API second patch is tap patch, that uses the API in the first patch > diff --git a/drivers/net/tap/rte_eth_tap.c b/drivers/net/tap/rte_eth_tap.c > index f1b48cae82..f6c25d7e21 100644 > --- a/drivers/net/tap/rte_eth_tap.c > +++ b/drivers/net/tap/rte_eth_tap.c > @@ -66,7 +66,7 @@ > (TAP_GSO_MBUFS_PER_CORE * TAP_GSO_MBUF_CACHE_SIZE) > > /* IPC key for queue fds sync */ > -#define TAP_MP_KEY "tap_mp_sync_queues" > +#define TAP_MP_REQ_START_RXTX "tap_mp_req_start_rxtx" > We said we can drop "tap_mp_sync_queues", but thinking twice, will current implementation cover following usecase: - Primary applicaiton started with tap interface, all config, setup, start done - Secondary app started without any parameter Since primary already started, I think secondary fds will be wrong, what do you think? > #define TAP_IOV_DEFAULT_MAX 1024 > > @@ -880,11 +880,48 @@ tap_link_set_up(struct rte_eth_dev *dev) > return tap_ioctl(pmd, SIOCSIFFLAGS, &ifr, 1, LOCAL_AND_REMOTE); > } > > +static int tap_mp_req_on_rxtx(struct rte_eth_dev *dev) Can you please follow the coding convention: static int tap_mp_req_on_rxtx(struct rte_eth_dev *dev) { > +{ > + struct rte_mp_msg msg; > + struct ipc_queues *request_param = (struct ipc_queues *)msg.param; > + int err; > + int fd_iterator = 0; > + struct pmd_process_private *process_private = dev->process_private; > + int i; > + > + memset(&msg, 0, sizeof(msg)); > + strlcpy(msg.name, TAP_MP_REQ_START_RXTX, sizeof(msg.name)); > + strlcpy(request_param->port_name, dev->data->name, sizeof(request_param->port_name)); > + msg.len_param = sizeof(*request_param); > + for (i = 0; i < dev->data->nb_tx_queues; i++) { > + msg.fds[fd_iterator++] = process_private->txq_fds[i]; > + msg.num_fds++; > + request_param->txq_count++; > + } > + for (i = 0; i < dev->data->nb_rx_queues; i++) { > + msg.fds[fd_iterator++] = process_private->rxq_fds[i]; > + msg.num_fds++; > + request_param->rxq_count++; > + } > + > + err = rte_mp_sendmsg(&msg); > + if (err < 0) { > + TAP_LOG(ERR, "Failed to send start req to secondary %d", > + rte_errno); > + return -1; > + } > + > + return 0; > +} > + > static int > tap_dev_start(struct rte_eth_dev *dev) > { > int err, i; > > + if (rte_eal_process_type() == RTE_PROC_PRIMARY) > + tap_mp_req_on_rxtx(dev); > + > err = tap_intr_handle_set(dev, 1); > if (err) > return err; > @@ -901,6 +938,34 @@ tap_dev_start(struct rte_eth_dev *dev) > return err; > } > > +static int > +tap_mp_req_start_rxtx(const struct rte_mp_msg *request, __rte_unused const void *peer) > +{ I asked last time but I don't remember the response, what should be in the 'peer' variable? > + struct rte_eth_dev *dev; > + const struct ipc_queues *request_param = > + (const struct ipc_queues *)request->param; > + int fd_iterator; > + int queue; > + struct pmd_process_private *process_private; > + > + dev = rte_get_eth_dev_by_name(request_param->port_name); > + if (!dev) { > + TAP_LOG(ERR, "Failed to get dev for %s", > + request_param->port_name); > + return -1; > + } > + process_private = dev->process_private; > + fd_iterator = 0; > + TAP_LOG(DEBUG, "tap_attach rx_q:%d tx_q:%d\n", request_param->rxq_count, > + request_param->txq_count); > + for (queue = 0; queue < request_param->txq_count; queue++) > + process_private->txq_fds[queue] = request->fds[fd_iterator++]; > + for (queue = 0; queue < request_param->rxq_count; queue++) > + process_private->rxq_fds[queue] = request->fds[fd_iterator++]; > + > + return 0; > +} > + > /* This function gets called when the current port gets stopped. > */ > static int > @@ -1084,6 +1149,7 @@ tap_dev_close(struct rte_eth_dev *dev) > > if (rte_eal_process_type() != RTE_PROC_PRIMARY) { > rte_free(dev->process_private); > + rte_mp_action_unregister(TAP_MP_REQ_START_RXTX); > return 0; > } > > @@ -1140,8 +1206,6 @@ tap_dev_close(struct rte_eth_dev *dev) > internals->ioctl_sock = -1; > } > rte_free(dev->process_private); > - if (tap_devices_count == 1) > - rte_mp_action_unregister(TAP_MP_KEY); > tap_devices_count--; > /* > * Since TUN device has no more opened file descriptors > @@ -2292,113 +2356,6 @@ rte_pmd_tun_probe(struct rte_vdev_device *dev) > return ret; > } > > -/* Request queue file descriptors from secondary to primary. */ > -static int > -tap_mp_attach_queues(const char *port_name, struct rte_eth_dev *dev) > -{ > - int ret; > - struct timespec timeout = {.tv_sec = 1, .tv_nsec = 0}; > - struct rte_mp_msg request, *reply; > - struct rte_mp_reply replies; > - struct ipc_queues *request_param = (struct ipc_queues *)request.param; > - struct ipc_queues *reply_param; > - struct pmd_process_private *process_private = dev->process_private; > - int queue, fd_iterator; > - > - /* Prepare the request */ > - memset(&request, 0, sizeof(request)); > - strlcpy(request.name, TAP_MP_KEY, sizeof(request.name)); > - strlcpy(request_param->port_name, port_name, > - sizeof(request_param->port_name)); > - request.len_param = sizeof(*request_param); > - /* Send request and receive reply */ > - ret = rte_mp_request_sync(&request, &replies, &timeout); > - if (ret < 0 || replies.nb_received != 1) { > - TAP_LOG(ERR, "Failed to request queues from primary: %d", > - rte_errno); > - return -1; > - } > - reply = &replies.msgs[0]; > - reply_param = (struct ipc_queues *)reply->param; > - TAP_LOG(DEBUG, "Received IPC reply for %s", reply_param->port_name); > - > - /* Attach the queues from received file descriptors */ > - if (reply_param->rxq_count + reply_param->txq_count != reply->num_fds) { > - TAP_LOG(ERR, "Unexpected number of fds received"); > - return -1; > - } > - > - dev->data->nb_rx_queues = reply_param->rxq_count; > - dev->data->nb_tx_queues = reply_param->txq_count; > - fd_iterator = 0; > - for (queue = 0; queue < reply_param->rxq_count; queue++) > - process_private->rxq_fds[queue] = reply->fds[fd_iterator++]; > - for (queue = 0; queue < reply_param->txq_count; queue++) > - process_private->txq_fds[queue] = reply->fds[fd_iterator++]; > - free(reply); > - return 0; > -} > - > -/* Send the queue file descriptors from the primary process to secondary. */ > -static int > -tap_mp_sync_queues(const struct rte_mp_msg *request, const void *peer) > -{ > - struct rte_eth_dev *dev; > - struct pmd_process_private *process_private; > - struct rte_mp_msg reply; > - const struct ipc_queues *request_param = > - (const struct ipc_queues *)request->param; > - struct ipc_queues *reply_param = > - (struct ipc_queues *)reply.param; > - uint16_t port_id; > - int queue; > - int ret; > - > - /* Get requested port */ > - TAP_LOG(DEBUG, "Received IPC request for %s", request_param->port_name); > - ret = rte_eth_dev_get_port_by_name(request_param->port_name, &port_id); > - if (ret) { > - TAP_LOG(ERR, "Failed to get port id for %s", > - request_param->port_name); > - return -1; > - } > - dev = &rte_eth_devices[port_id]; > - process_private = dev->process_private; > - > - /* Fill file descriptors for all queues */ > - reply.num_fds = 0; > - reply_param->rxq_count = 0; > - if (dev->data->nb_rx_queues + dev->data->nb_tx_queues > > - RTE_MP_MAX_FD_NUM){ > - TAP_LOG(ERR, "Number of rx/tx queues exceeds max number of fds"); > - return -1; > - } > - > - for (queue = 0; queue < dev->data->nb_rx_queues; queue++) { > - reply.fds[reply.num_fds++] = process_private->rxq_fds[queue]; > - reply_param->rxq_count++; > - } > - RTE_ASSERT(reply_param->rxq_count == dev->data->nb_rx_queues); > - > - reply_param->txq_count = 0; > - for (queue = 0; queue < dev->data->nb_tx_queues; queue++) { > - reply.fds[reply.num_fds++] = process_private->txq_fds[queue]; > - reply_param->txq_count++; > - } > - RTE_ASSERT(reply_param->txq_count == dev->data->nb_tx_queues); > - > - /* Send reply */ > - strlcpy(reply.name, request->name, sizeof(reply.name)); > - strlcpy(reply_param->port_name, request_param->port_name, > - sizeof(reply_param->port_name)); > - reply.len_param = sizeof(*reply_param); > - if (rte_mp_reply(&reply, peer) < 0) { > - TAP_LOG(ERR, "Failed to reply an IPC request to sync queues"); > - return -1; > - } > - return 0; > -} > - > /* Open a TAP interface device. > */ > static int > @@ -2442,9 +2399,11 @@ rte_pmd_tap_probe(struct rte_vdev_device *dev) > return -1; > } > > - ret = tap_mp_attach_queues(name, eth_dev); > - if (ret != 0) > - return -1; > + ret = rte_mp_action_register(TAP_MP_REQ_START_RXTX, tap_mp_req_start_rxtx); > + if (ret < 0 && rte_errno != ENOTSUP) > + TAP_LOG(ERR, "tap: Failed to register IPC callback: %s", > + strerror(rte_errno)); > + > rte_eth_dev_probing_finish(eth_dev); > return 0; > } > @@ -2492,15 +2451,6 @@ rte_pmd_tap_probe(struct rte_vdev_device *dev) > > TAP_LOG(DEBUG, "Initializing pmd_tap for %s", name); > > - /* Register IPC feed callback */ > - if (!tap_devices_count) { > - ret = rte_mp_action_register(TAP_MP_KEY, tap_mp_sync_queues); > - if (ret < 0 && rte_errno != ENOTSUP) { > - TAP_LOG(ERR, "tap: Failed to register IPC callback: %s", > - strerror(rte_errno)); > - goto leave; > - } > - } > tap_devices_count++; > tap_devices_count_increased = 1; > ret = eth_dev_tap_create(dev, tap_name, remote_iface, &user_mac, > @@ -2511,8 +2461,6 @@ rte_pmd_tap_probe(struct rte_vdev_device *dev) > TAP_LOG(ERR, "Failed to create pmd for %s as %s", > name, tap_name); > if (tap_devices_count_increased == 1) { > - if (tap_devices_count == 1) > - rte_mp_action_unregister(TAP_MP_KEY); > tap_devices_count--; > } > } > diff --git a/lib/ethdev/ethdev_driver.h b/lib/ethdev/ethdev_driver.h > index d95605a355..a08991bcdf 100644 > --- a/lib/ethdev/ethdev_driver.h > +++ b/lib/ethdev/ethdev_driver.h > @@ -1629,6 +1629,23 @@ rte_eth_hairpin_queue_peer_bind(uint16_t cur_port, uint16_t cur_queue, > struct rte_hairpin_peer_info *peer_info, > uint32_t direction); > > +/** Please add '@internal' tag into doxygen comment. > +* Get rte_eth_dev from device name. The device name should be specified > +* as below: > +* - PCIe address (Domain:Bus:Device.Function), for example- 0000:2:00.0 > +* - SoC device name, for example- fsl-gmac0 > +* - vdev dpdk name, for example- net_[pcap0|null0|tap0] > +* > +* @param name > +* pci address or name of the device > +* @return > +* - rte_eth_dev if successful > +* - NULL on failure > +*/ > +__rte_internal > +struct rte_eth_dev* > +rte_get_eth_dev_by_name(const char *name); As the API name, better to start with 'rte_eth_' prefix to be consistent with rest of the APIs. I suggest 'rte_eth_dev_get_by_name' but feel free to chose better one. > + > /** > * @internal > * Reset the current queue state and configuration to disconnect (unbind) it > diff --git a/lib/ethdev/rte_ethdev.c b/lib/ethdev/rte_ethdev.c > index a1d475a292..9192b0d664 100644 > --- a/lib/ethdev/rte_ethdev.c > +++ b/lib/ethdev/rte_ethdev.c > @@ -894,6 +894,17 @@ rte_eth_dev_get_port_by_name(const char *name, uint16_t *port_id) > return -ENODEV; > } > > +struct rte_eth_dev * > +rte_get_eth_dev_by_name(const char *name) > +{ > + uint16_t pid; > + > + if (rte_eth_dev_get_port_by_name(name, &pid)) > + return NULL; > + > + return &rte_eth_devices[pid]; > +} > + > static int > eth_err(uint16_t port_id, int ret) > { > diff --git a/lib/ethdev/version.map b/lib/ethdev/version.map > index c2fb0669a4..7e3797189b 100644 > --- a/lib/ethdev/version.map > +++ b/lib/ethdev/version.map > @@ -256,6 +256,7 @@ EXPERIMENTAL { > rte_flow_flex_item_create; > rte_flow_flex_item_release; > rte_flow_pick_transfer_proxy; > + This is unintendent change. > }; > > INTERNAL { > @@ -282,4 +283,5 @@ INTERNAL { > rte_eth_representor_id_get; > rte_eth_switch_domain_alloc; > rte_eth_switch_domain_free; > + rte_get_eth_dev_by_name; Please add in a sorted way. > };