From mboxrd@z Thu Jan 1 00:00:00 1970 Return-Path: Received: from dpdk.org (dpdk.org [92.243.14.124]) by inbox.dpdk.org (Postfix) with ESMTP id 3995DA0555 for ; Wed, 19 Feb 2020 12:49:55 +0100 (CET) Received: from [92.243.14.124] (localhost [127.0.0.1]) by dpdk.org (Postfix) with ESMTP id 2DAE71BFA0; Wed, 19 Feb 2020 12:49:55 +0100 (CET) Received: from dish-sg.nttdocomo.co.jp (dish-sg.nttdocomo.co.jp [202.19.227.74]) by dpdk.org (Postfix) with ESMTP id 5EF661BF8C for ; Wed, 19 Feb 2020 12:49:53 +0100 (CET) X-dD-Source: Outbound Received: from zssg-mailmd104.ddreams.local (zssg-mailmd900.ddreams.local [10.160.172.63]) by zssg-mailou103.ddreams.local (Postfix) with ESMTP id 2E3111200DE; Wed, 19 Feb 2020 20:49:52 +0900 (JST) Received: from zssg-mailmf101.ddreams.local (zssg-mailmf900.ddreams.local [10.160.172.84]) by zssg-mailmd104.ddreams.local (dDREAMS) with ESMTP id <0Q5Y00VI7674OG10@dDREAMS>; Wed, 19 Feb 2020 20:49:52 +0900 (JST) Received: from zssg-mailmf101.ddreams.local (unknown [127.0.0.1]) by zssg-mailmf101.ddreams.local (Postfix) with ESMTP id 006407E603A; Wed, 19 Feb 2020 20:49:52 +0900 (JST) Received: from zssg-mailmf101.ddreams.local (unknown [127.0.0.1]) by IMSVA (Postfix) with ESMTP id F300A8E6055; Wed, 19 Feb 2020 20:49:51 +0900 (JST) Received: from localhost (unknown [127.0.0.1]) by IMSVA (Postfix) with SMTP id F11E08E6054; Wed, 19 Feb 2020 20:49:51 +0900 (JST) X-IMSS-HAND-OFF-DIRECTIVE: localhost:10026 Received: from zssg-mailmf101.ddreams.local (unknown [127.0.0.1]) by IMSVA (Postfix) with ESMTP id 7A4868E6051; Wed, 19 Feb 2020 20:49:51 +0900 (JST) Received: from davinci.ntt-tx.co.jp (unknown [10.160.183.139]) by zssg-mailmf101.ddreams.local (Postfix) with ESMTP; Wed, 19 Feb 2020 20:49:51 +0900 (JST) From: x-fn-spp-ml@ntt-tx.co.jp To: spp@dpdk.org, ferruh.yigit@intel.com, yasufum.o@gmail.com Date: Wed, 19 Feb 2020 20:49:33 +0900 Message-id: <20200219114947.14134-4-x-fn-spp-ml@ntt-tx.co.jp> X-Mailer: git-send-email 2.18.0 In-reply-to: <20200218063720.6597-1-x-fn-spp-ml@ntt-tx.co.jp> References: <20200218063720.6597-1-x-fn-spp-ml@ntt-tx.co.jp> X-TM-AS-GCONF: 00 Subject: [spp] [PATCH v2 03/17] spp_mirror: add support of multi-queue X-BeenThere: spp@dpdk.org X-Mailman-Version: 2.1.15 Precedence: list List-Id: Soft Patch Panel List-Unsubscribe: , List-Archive: List-Post: List-Help: List-Subscribe: , Errors-To: spp-bounces@dpdk.org Sender: "spp" From: Hideyuki Yamashita By changing common code under shared directory to achieve multi-queue, existing code of spp_mirror should be changed also for successful compile. Signed-off-by: Hideyuki Yamashita Signed-off-by: Yasufumi Ogawa --- src/mirror/mir_cmd_runner.c | 3 ++- src/mirror/spp_mirror.c | 12 ++++++++---- 2 files changed, 10 insertions(+), 5 deletions(-) diff --git a/src/mirror/mir_cmd_runner.c b/src/mirror/mir_cmd_runner.c index fb1695f..5153b65 100644 --- a/src/mirror/mir_cmd_runner.c +++ b/src/mirror/mir_cmd_runner.c @@ -156,7 +156,8 @@ update_port(enum sppwk_action wk_action, sppwk_get_mng_data(NULL, &comp_info_base, NULL, NULL, &change_component, NULL); comp_info = (comp_info_base + comp_lcore_id); - port_info = get_sppwk_port(port->iface_type, port->iface_no); + port_info = get_sppwk_port(port->iface_type, port->iface_no, + port->queue_no); if (dir == SPPWK_PORT_DIR_RX) { nof_ports = &comp_info->nof_rx; ports = comp_info->rx_ports; diff --git a/src/mirror/spp_mirror.c b/src/mirror/spp_mirror.c index e5852aa..2bfbf66 100644 --- a/src/mirror/spp_mirror.c +++ b/src/mirror/spp_mirror.c @@ -340,7 +340,8 @@ mirror_proc(int id) nb_rx = sppwk_eth_ring_stats_rx_burst(rx->ethdev_port_id, rx->iface_type, rx->iface_no, 0, bufs, MAX_PKT_BURST); #else - nb_rx = rte_eth_rx_burst(rx->ethdev_port_id, 0, bufs, MAX_PKT_BURST); + nb_rx = rte_eth_rx_burst(rx->ethdev_port_id, rx->queue_no, bufs, + MAX_PKT_BURST); #endif if (unlikely(nb_rx == 0)) @@ -403,8 +404,8 @@ mirror_proc(int id) tx->ethdev_port_id, tx->iface_type, tx->iface_no, 0, copybufs, cnt); #else - nb_tx2 = rte_eth_tx_burst(tx->ethdev_port_id, 0, - copybufs, cnt); + nb_tx2 = rte_eth_tx_burst(tx->ethdev_port_id, + tx->queue_no, copybufs, cnt); #endif } @@ -415,7 +416,8 @@ mirror_proc(int id) nb_tx1 = sppwk_eth_ring_stats_tx_burst(tx->ethdev_port_id, tx->iface_type, tx->iface_no, 0, bufs, nb_rx); #else - nb_tx1 = rte_eth_tx_burst(tx->ethdev_port_id, 0, bufs, nb_rx); + nb_tx1 = rte_eth_tx_burst(tx->ethdev_port_id, tx->queue_no, + bufs, nb_rx); #endif nb_tx = nb_tx1; @@ -685,12 +687,14 @@ get_mirror_status(unsigned int lcore_id, int id, for (cnt = 0; cnt < path->nof_rx; cnt++) { rx_ports[cnt].iface_type = path->ports[cnt].rx.iface_type; rx_ports[cnt].iface_no = path->ports[cnt].rx.iface_no; + rx_ports[cnt].queue_no = path->ports[cnt].rx.queue_no; } memset(tx_ports, 0x00, sizeof(tx_ports)); for (cnt = 0; cnt < path->nof_tx; cnt++) { tx_ports[cnt].iface_type = path->ports[cnt].tx.iface_type; tx_ports[cnt].iface_no = path->ports[cnt].tx.iface_no; + tx_ports[cnt].queue_no = path->ports[cnt].tx.queue_no; } /* Set the information with the function specified by the command. */ -- 2.17.1