From patchwork Fri Nov 18 09:08:42 2016 Content-Type: text/plain; charset="utf-8" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit X-Patchwork-Submitter: Linhaifeng X-Patchwork-Id: 17088 X-Patchwork-Delegate: ferruh.yigit@amd.com Return-Path: X-Original-To: patchwork@dpdk.org Delivered-To: patchwork@dpdk.org Received: from [92.243.14.124] (localhost [IPv6:::1]) by dpdk.org (Postfix) with ESMTP id 901F85591; Fri, 18 Nov 2016 10:09:13 +0100 (CET) Received: from szxga02-in.huawei.com (unknown [119.145.14.65]) by dpdk.org (Postfix) with ESMTP id 72E3937B2 for ; Fri, 18 Nov 2016 10:09:03 +0100 (CET) Received: from 172.24.1.136 (EHLO szxeml434-hub.china.huawei.com) ([172.24.1.136]) by szxrg02-dlp.huawei.com (MOS 4.3.7-GA FastPath queued) with ESMTP id DQX20579; Fri, 18 Nov 2016 17:08:51 +0800 (CST) Received: from localhost (10.177.20.223) by szxeml434-hub.china.huawei.com (10.82.67.225) with Microsoft SMTP Server id 14.3.235.1; Fri, 18 Nov 2016 17:08:44 +0800 From: Haifeng Lin To: CC: , Date: Fri, 18 Nov 2016 17:08:42 +0800 Message-ID: <1479460122-18780-1-git-send-email-haifeng.lin@huawei.com> X-Mailer: git-send-email 1.8.5.2.msysgit.0 MIME-Version: 1.0 X-Originating-IP: [10.177.20.223] X-CFilter-Loop: Reflected Subject: [dpdk-dev] [PATCH] net/bonding: improve non-ip packets RSS X-BeenThere: dev@dpdk.org X-Mailman-Version: 2.1.15 Precedence: list List-Id: patches and discussions about DPDK List-Unsubscribe: , List-Archive: List-Post: List-Help: List-Subscribe: , Errors-To: dev-bounces@dpdk.org Sender: "dev" Most ethernet not support non-ip packets RSS and only first queue can used to receive. In this scenario lacp bond can only use one queue even if multi queue configured. We use below formula to change the map between bond_qid and slave_qid to let at least slave_num queues to receive packets: slave_qid = (bond_qid + slave_id) % queue_num Signed-off-by: Haifeng Lin --- drivers/net/bonding/rte_eth_bond_pmd.c | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) diff --git a/drivers/net/bonding/rte_eth_bond_pmd.c b/drivers/net/bonding/rte_eth_bond_pmd.c index 09ce7bf..8ad843a 100644 --- a/drivers/net/bonding/rte_eth_bond_pmd.c +++ b/drivers/net/bonding/rte_eth_bond_pmd.c @@ -141,6 +141,8 @@ bond_ethdev_rx_burst_8023ad(void *queue, struct rte_mbuf **bufs, uint8_t collecting; /* current slave collecting status */ const uint8_t promisc = internals->promiscuous_en; uint8_t i, j, k; + int slave_qid, bond_qid = bd_rx_q->queue_id; + int queue_num = internals->nb_rx_queues; rte_eth_macaddr_get(internals->port_id, &bond_mac); /* Copy slave list to protect against slave up/down changes during tx @@ -154,7 +156,9 @@ bond_ethdev_rx_burst_8023ad(void *queue, struct rte_mbuf **bufs, collecting = ACTOR_STATE(&mode_8023ad_ports[slaves[i]], COLLECTING); /* Read packets from this slave */ - num_rx_total += rte_eth_rx_burst(slaves[i], bd_rx_q->queue_id, + slave_qid = queue_num ? (bond_qid + slaves[i]) % queue_num : + bond_qid; + num_rx_total += rte_eth_rx_burst(slaves[i], slave_qid, &bufs[num_rx_total], nb_pkts - num_rx_total); for (k = j; k < 2 && k < num_rx_total; k++)