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 492C0A0524 for ; Tue, 25 Feb 2020 06:56:46 +0100 (CET) Received: from [92.243.14.124] (localhost [127.0.0.1]) by dpdk.org (Postfix) with ESMTP id 438D91BFC8; Tue, 25 Feb 2020 06:56:46 +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 9529A2C4F for ; Tue, 25 Feb 2020 06:56:44 +0100 (CET) X-dD-Source: Outbound Received: from zssg-mailmd105.ddreams.local (zssg-mailmd900.ddreams.local [10.160.172.63]) by zssg-mailou102.ddreams.local (Postfix) with ESMTP id D2370120100; Tue, 25 Feb 2020 14:56:43 +0900 (JST) Received: from zssg-mailmf101.ddreams.local (zssg-mailmf900.ddreams.local [10.160.172.84]) by zssg-mailmd105.ddreams.local (dDREAMS) with ESMTP id <0Q68012PTTUJ1690@dDREAMS>; Tue, 25 Feb 2020 14:56:43 +0900 (JST) Received: from zssg-mailmf101.ddreams.local (unknown [127.0.0.1]) by zssg-mailmf101.ddreams.local (Postfix) with ESMTP id B40617E6034; Tue, 25 Feb 2020 14:56:43 +0900 (JST) Received: from zssg-mailmf101.ddreams.local (unknown [127.0.0.1]) by IMSVA (Postfix) with ESMTP id B2D3E8E605D; Tue, 25 Feb 2020 14:56:43 +0900 (JST) Received: from localhost (unknown [127.0.0.1]) by IMSVA (Postfix) with SMTP id B1C4A8E605C; Tue, 25 Feb 2020 14:56:43 +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 8317E8E605A; Tue, 25 Feb 2020 14:56:42 +0900 (JST) Received: from davinci.ntt-tx.co.jp (unknown [10.160.183.139]) by zssg-mailmf101.ddreams.local (Postfix) with ESMTP; Tue, 25 Feb 2020 14:56:42 +0900 (JST) From: x-fn-spp-ml@ntt-tx.co.jp To: spp@dpdk.org, ferruh.yigit@intel.com, yasufum.o@gmail.com Date: Tue, 25 Feb 2020 14:56:25 +0900 Message-id: <20200225055639.31616-4-x-fn-spp-ml@ntt-tx.co.jp> X-Mailer: git-send-email 2.18.0 In-reply-to: <20200219112155.13964-1-yamashita.hideyuki@ntt-tx.co.jp> References: <20200219112155.13964-1-yamashita.hideyuki@ntt-tx.co.jp> X-TM-AS-GCONF: 00 Subject: [spp] [PATCH v3 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: Naoki Takada --- 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