From mboxrd@z Thu Jan 1 00:00:00 1970 From: Jeff Guo Subject: [PATCH V20 4/4] app/testpmd: show example to handler hot unplug Date: Wed, 18 Apr 2018 21:38:09 +0800 Message-ID: <1524058689-4954-5-git-send-email-jia.guo@intel.com> References: <1498711073-42917-1-git-send-email-jia.guo@intel.com> <1524058689-4954-1-git-send-email-jia.guo@intel.com> Cc: jblunck@infradead.org, shreyansh.jain@nxp.com, dev@dpdk.org, jia.guo@intel.com, helin.zhang@intel.com To: stephen@networkplumber.org, bruce.richardson@intel.com, ferruh.yigit@intel.com, konstantin.ananyev@intel.com, gaetan.rivet@6wind.com, jingjing.wu@intel.com, thomas@monjalon.net, motih@mellanox.com, matan@mellanox.com, harry.van.haaren@intel.com, jianfeng.tan@intel.com Return-path: Received: from mga03.intel.com (mga03.intel.com [134.134.136.65]) by dpdk.org (Postfix) with ESMTP id D68E0AAB9 for ; Wed, 18 Apr 2018 15:39:35 +0200 (CEST) In-Reply-To: <1524058689-4954-1-git-send-email-jia.guo@intel.com> List-Id: DPDK patches and discussions List-Unsubscribe: , List-Archive: List-Post: List-Help: List-Subscribe: , Errors-To: dev-bounces@dpdk.org Sender: "dev" 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 --- v20->v19: remove the auto binding example. --- app/test-pmd/testpmd.c | 29 +++++++++++++++++++++++++---- 1 file changed, 25 insertions(+), 4 deletions(-) diff --git a/app/test-pmd/testpmd.c b/app/test-pmd/testpmd.c index 5986ff7..3751901 100644 --- a/app/test-pmd/testpmd.c +++ b/app/test-pmd/testpmd.c @@ -1125,6 +1125,9 @@ run_pkt_fwd_on_lcore(struct fwd_lcore *fc, packet_fwd_t pkt_fwd) tics_datum = rte_rdtsc(); tics_per_1sec = rte_get_timer_hz(); #endif + if (hot_plug) + rte_dev_handle_hot_unplug(); + fsm = &fwd_streams[fc->stream_idx]; nb_fs = fc->stream_nb; do { @@ -2069,6 +2072,26 @@ rmv_event_callback(void *arg) dev->device->name); } +static void +rmv_dev_event_callback(char *dev_name) +{ + uint16_t port_id; + int ret; + + ret = rte_eth_dev_get_port_by_name(dev_name, &port_id); + if (ret) { + printf("can not get port by device %s!\n", dev_name); + return; + } + + RTE_ETH_VALID_PORTID_OR_RET(port_id); + printf("removing port id:%u\n", port_id); + stop_packet_forwarding(); + stop_port(port_id); + close_port(port_id); + detach_port(port_id); +} + /* This function is used by the interrupt thread */ static int eth_event_callback(portid_t port_id, enum rte_eth_event_type type, void *param, @@ -2130,9 +2153,7 @@ eth_dev_event_callback(char *device_name, enum rte_dev_event_type 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_dev_event_callback(device_name); break; case RTE_DEV_EVENT_ADD: RTE_LOG(ERR, EAL, "The device: %s has been added!\n", @@ -2640,7 +2661,7 @@ main(int argc, char** argv) return -1; } eth_dev_event_callback_register(); - + rte_dev_handle_hot_unplug(); } if (start_port(RTE_PORT_ALL) != 0) -- 2.7.4