From mboxrd@z Thu Jan 1 00:00:00 1970 Return-Path: Received: from mga11.intel.com (mga11.intel.com [192.55.52.93]) by dpdk.org (Postfix) with ESMTP id 22C331D8D9 for ; Fri, 15 Jun 2018 10:32:44 +0200 (CEST) X-Amp-Result: SKIPPED(no attachment in message) X-Amp-File-Uploaded: False Received: from fmsmga006.fm.intel.com ([10.253.24.20]) by fmsmga102.fm.intel.com with ESMTP/TLS/DHE-RSA-AES256-GCM-SHA384; 15 Jun 2018 01:32:44 -0700 X-ExtLoop1: 1 X-IronPort-AV: E=Sophos;i="5.51,226,1526367600"; d="scan'208";a="237671431" Received: from jguo15x-mobl3.ccr.corp.intel.com (HELO [10.67.68.54]) ([10.67.68.54]) by fmsmga006.fm.intel.com with ESMTP; 15 Jun 2018 01:32:41 -0700 To: "Iremonger, Bernard" , "stephen@networkplumber.org" , "Richardson, Bruce" , "Yigit, Ferruh" , "Ananyev, Konstantin" , "gaetan.rivet@6wind.com" , "Wu, Jingjing" , "thomas@monjalon.net" , "motih@mellanox.com" , "matan@mellanox.com" , "Van Haaren, Harry" , "Tan, Jianfeng" References: <1498711073-42917-1-git-send-email-jia.guo@intel.com> <1525344524-26946-1-git-send-email-jia.guo@intel.com> <1525344524-26946-5-git-send-email-jia.guo@intel.com> <8CEF83825BEC744B83065625E567D7C260CB36FD@IRSMSX108.ger.corp.intel.com> Cc: "jblunck@infradead.org" , "shreyansh.jain@nxp.com" , "dev@dpdk.org" , "Zhang, Helin" From: "Guo, Jia" Message-ID: <5c7613d6-fe93-cb14-4f23-84825e639413@intel.com> Date: Fri, 15 Jun 2018 16:32:41 +0800 User-Agent: Mozilla/5.0 (Windows NT 6.3; WOW64; rv:45.0) Gecko/20100101 Thunderbird/45.4.0 MIME-Version: 1.0 In-Reply-To: <8CEF83825BEC744B83065625E567D7C260CB36FD@IRSMSX108.ger.corp.intel.com> Content-Type: text/plain; charset=windows-1252; format=flowed Content-Transfer-Encoding: 7bit Subject: Re: [dpdk-dev] [PATCH V21 4/4] app/testpmd: show example to handle hot unplug 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: Fri, 15 Jun 2018 08:32:45 -0000 On 6/14/2018 8:59 PM, Iremonger, Bernard wrote: > Hi Jeff, > >> -----Original Message----- >> From: dev [mailto:dev-bounces@dpdk.org] On Behalf Of Jeff Guo >> Sent: Thursday, May 3, 2018 11:49 AM >> To: stephen@networkplumber.org; Richardson, Bruce >> ; Yigit, Ferruh ; >> Ananyev, Konstantin ; >> gaetan.rivet@6wind.com; Wu, Jingjing ; >> thomas@monjalon.net; motih@mellanox.com; matan@mellanox.com; Van >> Haaren, Harry ; Tan, Jianfeng >> >> Cc: jblunck@infradead.org; shreyansh.jain@nxp.com; dev@dpdk.org; Guo, >> Jia ; Zhang, Helin >> Subject: [dpdk-dev] [PATCH V21 4/4] app/testpmd: show example to handle >> hot unplug >> >> Use testpmd for example, to show how an application smoothly handle >> failure when device being hot unplug. Once app detect the removal event, >> the callback would be called, it first stop the packet forwarding, then stop the >> port, close the port and finally detach the port. >> >> Signed-off-by: Jeff Guo >> --- >> v21->v20: >> fix attach port issue, let it work for multiple device case. >> combind rmv callback to only one. >> --- >> app/test-pmd/testpmd.c | 27 ++++++++++++++++++--------- >> 1 file changed, 18 insertions(+), 9 deletions(-) >> >> diff --git a/app/test-pmd/testpmd.c b/app/test-pmd/testpmd.c index >> db23f23..a1ff8f3 100644 >> --- a/app/test-pmd/testpmd.c >> +++ b/app/test-pmd/testpmd.c >> @@ -1908,9 +1908,10 @@ eth_dev_event_callback_unregister(void) >> void >> attach_port(char *identifier) >> { >> - portid_t pi = 0; >> unsigned int socket_id; >> >> + portid_t pi = rte_eth_dev_count_avail(); >> + >> printf("Attaching a new port...\n"); >> >> if (identifier == NULL) { >> @@ -2071,12 +2072,14 @@ rmv_event_callback(void *arg) >> RTE_ETH_VALID_PORTID_OR_RET(port_id); >> dev = &rte_eth_devices[port_id]; >> >> + if (dev->state == RTE_ETH_DEV_UNUSED) >> + return; >> + >> + printf("removing device %s\n", dev->device->name); >> + stop_packet_forwarding(); >> stop_port(port_id); >> close_port(port_id); >> - printf("removing device %s\n", dev->device->name); >> - if (rte_eal_dev_detach(dev->device)) >> - TESTPMD_LOG(ERR, "Failed to detach device %s\n", >> - dev->device->name); >> + detach_port(port_id); >> } >> >> /* This function is used by the interrupt thread */ @@ -2131,19 +2134,26 >> @@ static void eth_dev_event_callback(char *device_name, enum >> rte_dev_event_type type, >> __rte_unused void *arg) >> { >> + uint16_t port_id; >> + int ret; >> + >> if (type >= RTE_DEV_EVENT_MAX) { >> fprintf(stderr, "%s called upon invalid event %d\n", >> __func__, type); >> fflush(stderr); >> } >> >> + ret = rte_eth_dev_get_port_by_name(device_name, &port_id); >> + if (ret) { >> + printf("can not get port by device %s!\n", device_name); >> + return; >> + } >> + >> switch (type) { >> case RTE_DEV_EVENT_REMOVE: >> RTE_LOG(ERR, EAL, "The device: %s has been removed!\n", >> device_name); >> - /* TODO: After finish failure handle, begin to stop >> - * packet forward, stop port, close port, detach port. >> - */ >> + rmv_event_callback((void *)(intptr_t)port_id); >> break; >> case RTE_DEV_EVENT_ADD: >> RTE_LOG(ERR, EAL, "The device: %s has been added!\n", >> @@ -2666,7 +2676,6 @@ main(int argc, char** argv) >> return -1; >> } >> eth_dev_event_callback_register(); >> - >> } >> >> if (start_port(RTE_PORT_ALL) != 0) >> -- >> 2.7.4 > This patch fails to apply to dpdk 18.08-rc0 and needs to be rebased. > > Regards, > > Bernard. thanks your notify, bernard, the coming next patch set will update to fix it.