Update driver to be similar to the "ice" driver and use the common mbuf
ring cleanup code on shutdown of a Tx queue.

Signed-off-by: Bruce Richardson <bruce.richard...@intel.com>
---
 drivers/net/intel/i40e/i40e_ethdev.h |  4 +-
 drivers/net/intel/i40e/i40e_rxtx.c   | 70 +++-------------------------
 drivers/net/intel/i40e/i40e_rxtx.h   |  1 -
 3 files changed, 9 insertions(+), 66 deletions(-)

diff --git a/drivers/net/intel/i40e/i40e_ethdev.h 
b/drivers/net/intel/i40e/i40e_ethdev.h
index d351193ed9..ccc8732d7d 100644
--- a/drivers/net/intel/i40e/i40e_ethdev.h
+++ b/drivers/net/intel/i40e/i40e_ethdev.h
@@ -1260,12 +1260,12 @@ struct i40e_adapter {
 
        /* For RSS reta table update */
        uint8_t rss_reta_updated;
-#ifdef RTE_ARCH_X86
+
+       /* used only on x86, zero on other architectures */
        bool rx_use_avx2;
        bool rx_use_avx512;
        bool tx_use_avx2;
        bool tx_use_avx512;
-#endif
 };
 
 /**
diff --git a/drivers/net/intel/i40e/i40e_rxtx.c 
b/drivers/net/intel/i40e/i40e_rxtx.c
index 539b170266..b70919c5dc 100644
--- a/drivers/net/intel/i40e/i40e_rxtx.c
+++ b/drivers/net/intel/i40e/i40e_rxtx.c
@@ -1875,6 +1875,7 @@ i40e_dev_tx_queue_start(struct rte_eth_dev *dev, uint16_t 
tx_queue_id)
        int err;
        struct ci_tx_queue *txq;
        struct i40e_hw *hw = I40E_DEV_PRIVATE_TO_HW(dev->data->dev_private);
+       const struct i40e_adapter *ad = 
I40E_DEV_PRIVATE_TO_ADAPTER(dev->data->dev_private);
 
        PMD_INIT_FUNC_TRACE();
 
@@ -1889,6 +1890,9 @@ i40e_dev_tx_queue_start(struct rte_eth_dev *dev, uint16_t 
tx_queue_id)
                PMD_DRV_LOG(WARNING, "TX queue %u is deferred start",
                            tx_queue_id);
 
+       txq->vector_tx = ad->tx_vec_allowed;
+       txq->vector_sw_ring = ad->tx_use_avx512;
+
        /*
         * tx_queue_id is queue id application refers to, while
         * rxq->reg_idx is the real queue index.
@@ -1929,7 +1933,7 @@ i40e_dev_tx_queue_stop(struct rte_eth_dev *dev, uint16_t 
tx_queue_id)
                return err;
        }
 
-       i40e_tx_queue_release_mbufs(txq);
+       ci_txq_release_all_mbufs(txq);
        i40e_reset_tx_queue(txq);
        dev->data->tx_queue_state[tx_queue_id] = RTE_ETH_QUEUE_STATE_STOPPED;
 
@@ -2604,7 +2608,7 @@ i40e_tx_queue_release(void *txq)
                return;
        }
 
-       i40e_tx_queue_release_mbufs(q);
+       ci_txq_release_all_mbufs(q);
        rte_free(q->sw_ring);
        rte_memzone_free(q->mz);
        rte_free(q);
@@ -2701,66 +2705,6 @@ i40e_reset_rx_queue(struct i40e_rx_queue *rxq)
        rxq->rxrearm_nb = 0;
 }
 
-void
-i40e_tx_queue_release_mbufs(struct ci_tx_queue *txq)
-{
-       struct rte_eth_dev *dev;
-       uint16_t i;
-
-       if (!txq || !txq->sw_ring) {
-               PMD_DRV_LOG(DEBUG, "Pointer to txq or sw_ring is NULL");
-               return;
-       }
-
-       dev = &rte_eth_devices[txq->port_id];
-
-       /**
-        *  vPMD tx will not set sw_ring's mbuf to NULL after free,
-        *  so need to free remains more carefully.
-        */
-#ifdef CC_AVX512_SUPPORT
-       if (dev->tx_pkt_burst == i40e_xmit_pkts_vec_avx512) {
-               struct ci_tx_entry_vec *swr = (void *)txq->sw_ring;
-
-               i = txq->tx_next_dd - txq->tx_rs_thresh + 1;
-               if (txq->tx_tail < i) {
-                       for (; i < txq->nb_tx_desc; i++) {
-                               rte_pktmbuf_free_seg(swr[i].mbuf);
-                               swr[i].mbuf = NULL;
-                       }
-                       i = 0;
-               }
-               for (; i < txq->tx_tail; i++) {
-                       rte_pktmbuf_free_seg(swr[i].mbuf);
-                       swr[i].mbuf = NULL;
-               }
-               return;
-       }
-#endif
-       if (dev->tx_pkt_burst == i40e_xmit_pkts_vec_avx2 ||
-                       dev->tx_pkt_burst == i40e_xmit_pkts_vec) {
-               i = txq->tx_next_dd - txq->tx_rs_thresh + 1;
-               if (txq->tx_tail < i) {
-                       for (; i < txq->nb_tx_desc; i++) {
-                               rte_pktmbuf_free_seg(txq->sw_ring[i].mbuf);
-                               txq->sw_ring[i].mbuf = NULL;
-                       }
-                       i = 0;
-               }
-               for (; i < txq->tx_tail; i++) {
-                       rte_pktmbuf_free_seg(txq->sw_ring[i].mbuf);
-                       txq->sw_ring[i].mbuf = NULL;
-               }
-       } else {
-               for (i = 0; i < txq->nb_tx_desc; i++) {
-                       if (txq->sw_ring[i].mbuf) {
-                               rte_pktmbuf_free_seg(txq->sw_ring[i].mbuf);
-                               txq->sw_ring[i].mbuf = NULL;
-                       }
-               }
-       }
-}
-
 static int
 i40e_tx_done_cleanup_full(struct ci_tx_queue *txq,
                        uint32_t free_cnt)
@@ -3127,7 +3071,7 @@ i40e_dev_clear_queues(struct rte_eth_dev *dev)
        for (i = 0; i < dev->data->nb_tx_queues; i++) {
                if (!dev->data->tx_queues[i])
                        continue;
-               i40e_tx_queue_release_mbufs(dev->data->tx_queues[i]);
+               ci_txq_release_all_mbufs(dev->data->tx_queues[i]);
                i40e_reset_tx_queue(dev->data->tx_queues[i]);
        }
 
diff --git a/drivers/net/intel/i40e/i40e_rxtx.h 
b/drivers/net/intel/i40e/i40e_rxtx.h
index c6d1bb53d0..2f32fc5686 100644
--- a/drivers/net/intel/i40e/i40e_rxtx.h
+++ b/drivers/net/intel/i40e/i40e_rxtx.h
@@ -179,7 +179,6 @@ void i40e_dev_clear_queues(struct rte_eth_dev *dev);
 void i40e_dev_free_queues(struct rte_eth_dev *dev);
 void i40e_reset_rx_queue(struct i40e_rx_queue *rxq);
 void i40e_reset_tx_queue(struct ci_tx_queue *txq);
-void i40e_tx_queue_release_mbufs(struct ci_tx_queue *txq);
 int i40e_tx_done_cleanup(void *txq, uint32_t free_cnt);
 int i40e_alloc_rx_queue_mbufs(struct i40e_rx_queue *rxq);
 void i40e_rx_queue_release_mbufs(struct i40e_rx_queue *rxq);
-- 
2.43.0

Reply via email to