[dpdk-dev] [PATCH 4/7] net/dpaa2: support external buffers in Tx

[Hemant Agrawal]

From: Nipun Gupta <nipun.gu...@nxp.com>

This patch support tx of external allocated buffers.

Signed-off-by: Nipun Gupta <nipun.gu...@nxp.com>
Acked-by: Hemant Agrawal <hemant.agra...@nxp.com>
---
 drivers/net/dpaa2/dpaa2_rxtx.c | 38 ++++++++++++++++++++++++++++++++++
 1 file changed, 38 insertions(+)

diff --git a/drivers/net/dpaa2/dpaa2_rxtx.c b/drivers/net/dpaa2/dpaa2_rxtx.c
index 7d2a7809d3..de297d8274 100644
--- a/drivers/net/dpaa2/dpaa2_rxtx.c
+++ b/drivers/net/dpaa2/dpaa2_rxtx.c
@@ -1065,6 +1065,7 @@ dpaa2_dev_tx(void *queue, struct rte_mbuf **bufs, 
uint16_t nb_pkts)
        struct rte_eth_dev_data *eth_data = dpaa2_q->eth_data;
        struct dpaa2_dev_priv *priv = eth_data->dev_private;
        uint32_t flags[MAX_TX_RING_SLOTS] = {0};
+       struct rte_mbuf **orig_bufs = bufs;
 
        if (unlikely(!DPAA2_PER_LCORE_DPIO)) {
                ret = dpaa2_affine_qbman_swp();
@@ -1148,6 +1149,25 @@ dpaa2_dev_tx(void *queue, struct rte_mbuf **bufs, 
uint16_t nb_pkts)
                                mi = rte_mbuf_from_indirect(*bufs);
                                mp = mi->pool;
                        }
+
+                       if (unlikely(RTE_MBUF_HAS_EXTBUF(*bufs))) {
+                               rte_mbuf_refcnt_update(*bufs, 1);
+                               if (unlikely((*bufs)->nb_segs > 1)) {
+                                       if (eth_mbuf_to_sg_fd(*bufs,
+                                                             &fd_arr[loop],
+                                                             mp, 0))
+                                               goto send_n_return;
+                               } else {
+                                       eth_mbuf_to_fd(*bufs,
+                                                      &fd_arr[loop], 0);
+                               }
+                               bufs++;
+#ifdef RTE_LIBRTE_IEEE1588
+                               enable_tx_tstamp(&fd_arr[loop]);
+#endif
+                               continue;
+                       }
+
                        /* Not a hw_pkt pool allocated frame */
                        if (unlikely(!mp || !priv->bp_list)) {
                                DPAA2_PMD_ERR("Err: No buffer pool attached");
@@ -1220,6 +1240,15 @@ dpaa2_dev_tx(void *queue, struct rte_mbuf **bufs, 
uint16_t nb_pkts)
                nb_pkts -= loop;
        }
        dpaa2_q->tx_pkts += num_tx;
+
+       loop = 0;
+       while (loop < num_tx) {
+               if (unlikely(RTE_MBUF_HAS_EXTBUF(*orig_bufs)))
+                       rte_pktmbuf_free(*orig_bufs);
+               orig_bufs++;
+               loop++;
+       }
+
        return num_tx;
 
 send_n_return:
@@ -1246,6 +1275,15 @@ dpaa2_dev_tx(void *queue, struct rte_mbuf **bufs, 
uint16_t nb_pkts)
        }
 skip_tx:
        dpaa2_q->tx_pkts += num_tx;
+
+       loop = 0;
+       while (loop < num_tx) {
+               if (unlikely(RTE_MBUF_HAS_EXTBUF(*orig_bufs)))
+                       rte_pktmbuf_free(*orig_bufs);
+               orig_bufs++;
+               loop++;
+       }
+
        return num_tx;
 }
 
-- 
2.17.1