From mboxrd@z Thu Jan 1 00:00:00 1970 From: Zhiyong Yang Subject: [PATCH 1/5] net/fm10k: remove limit of fm10k_xmit_pkts_vec burst size Date: Fri, 24 Feb 2017 16:48:17 +0800 Message-ID: <1487926101-4637-2-git-send-email-zhiyong.yang@intel.com> References: <1487926101-4637-1-git-send-email-zhiyong.yang@intel.com> Cc: Jing Chen , Zhiyong Yang To: dev@dpdk.org Return-path: Received: from mga09.intel.com (mga09.intel.com [134.134.136.24]) by dpdk.org (Postfix) with ESMTP id 800762BB2 for ; Fri, 24 Feb 2017 09:48:26 +0100 (CET) In-Reply-To: <1487926101-4637-1-git-send-email-zhiyong.yang@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" To add a wrapper function fm10k_xmit_pkts_vec_simple to remove the limit of tx burst size. The patch makes fm10k vec function an best effort to transmit the pkts in the consistent behavior like fm10k_xmit_pkts does that. Cc: Jing Chen Signed-off-by: Zhiyong Yang --- drivers/net/fm10k/fm10k_ethdev.c | 27 ++++++++++++++++++++++++++- 1 file changed, 26 insertions(+), 1 deletion(-) diff --git a/drivers/net/fm10k/fm10k_ethdev.c b/drivers/net/fm10k/fm10k_ethdev.c index c4fe746..e9b6254 100644 --- a/drivers/net/fm10k/fm10k_ethdev.c +++ b/drivers/net/fm10k/fm10k_ethdev.c @@ -2741,6 +2741,31 @@ fm10k_check_ftag(struct rte_devargs *devargs) return 1; } +static uint16_t +fm10k_xmit_pkts_vec_simple(void *tx_queue, struct rte_mbuf **tx_pkts, + uint16_t nb_pkts) +{ + uint16_t nb_tx = 0; + struct fm10k_tx_queue *txq = (struct fm10k_tx_queue *)tx_queue; + + if (likely(nb_pkts <= txq->rs_thresh)) + return fm10k_xmit_pkts_vec(tx_queue, tx_pkts, nb_pkts); + + /* transmit in chunks of at least txq->rs_thresh */ + while (nb_pkts) { + uint16_t ret, num; + + num = (uint16_t)RTE_MIN(nb_pkts, txq->rs_thresh); + ret = fm10k_xmit_pkts_vec(tx_queue, &tx_pkts[nb_tx], num); + nb_tx += ret; + nb_pkts -= ret; + if (ret < num) + break; + } + + return nb_tx; +} + static void __attribute__((cold)) fm10k_set_tx_function(struct rte_eth_dev *dev) { @@ -2766,7 +2791,7 @@ fm10k_set_tx_function(struct rte_eth_dev *dev) txq = dev->data->tx_queues[i]; fm10k_txq_vec_setup(txq); } - dev->tx_pkt_burst = fm10k_xmit_pkts_vec; + dev->tx_pkt_burst = fm10k_xmit_pkts_vec_simple; dev->tx_pkt_prepare = NULL; } else { dev->tx_pkt_burst = fm10k_xmit_pkts; -- 2.7.4