[v1 01/43] net/dpaa2: enhance Tx scatter-gather mempool

[vanshika . shukla]

From: Jun Yang <jun.y...@nxp.com>

Create TX SG pool only for primary process and lookup
this pool in secondary process.

Signed-off-by: Jun Yang <jun.y...@nxp.com>
---
 drivers/net/dpaa2/dpaa2_ethdev.c | 46 +++++++++++++++++++++++---------
 1 file changed, 33 insertions(+), 13 deletions(-)

diff --git a/drivers/net/dpaa2/dpaa2_ethdev.c b/drivers/net/dpaa2/dpaa2_ethdev.c
index 449bbda7ca..238533f439 100644
--- a/drivers/net/dpaa2/dpaa2_ethdev.c
+++ b/drivers/net/dpaa2/dpaa2_ethdev.c
@@ -2867,6 +2867,35 @@ int dpaa2_dev_is_dpaa2(struct rte_eth_dev *dev)
        return dev->device->driver == &rte_dpaa2_pmd.driver;
 }
 
+static int dpaa2_tx_sg_pool_init(void)
+{
+       char name[RTE_MEMZONE_NAMESIZE];
+
+       if (dpaa2_tx_sg_pool)
+               return 0;
+
+       sprintf(name, "dpaa2_mbuf_tx_sg_pool");
+       if (rte_eal_process_type() == RTE_PROC_PRIMARY) {
+               dpaa2_tx_sg_pool = rte_pktmbuf_pool_create(name,
+                       DPAA2_POOL_SIZE,
+                       DPAA2_POOL_CACHE_SIZE, 0,
+                       DPAA2_MAX_SGS * sizeof(struct qbman_sge),
+                       rte_socket_id());
+               if (!dpaa2_tx_sg_pool) {
+                       DPAA2_PMD_ERR("SG pool creation failed\n");
+                       return -ENOMEM;
+               }
+       } else {
+               dpaa2_tx_sg_pool = rte_mempool_lookup(name);
+               if (!dpaa2_tx_sg_pool) {
+                       DPAA2_PMD_ERR("SG pool lookup failed\n");
+                       return -ENOMEM;
+               }
+       }
+
+       return 0;
+}
+
 static int
 rte_dpaa2_probe(struct rte_dpaa2_driver *dpaa2_drv,
                struct rte_dpaa2_device *dpaa2_dev)
@@ -2921,19 +2950,10 @@ rte_dpaa2_probe(struct rte_dpaa2_driver *dpaa2_drv,
 
        /* Invoke PMD device initialization function */
        diag = dpaa2_dev_init(eth_dev);
-       if (diag == 0) {
-               if (!dpaa2_tx_sg_pool) {
-                       dpaa2_tx_sg_pool =
-                               rte_pktmbuf_pool_create("dpaa2_mbuf_tx_sg_pool",
-                               DPAA2_POOL_SIZE,
-                               DPAA2_POOL_CACHE_SIZE, 0,
-                               DPAA2_MAX_SGS * sizeof(struct qbman_sge),
-                               rte_socket_id());
-                       if (dpaa2_tx_sg_pool == NULL) {
-                               DPAA2_PMD_ERR("SG pool creation failed\n");
-                               return -ENOMEM;
-                       }
-               }
+       if (!diag) {
+               diag = dpaa2_tx_sg_pool_init();
+               if (diag)
+                       return diag;
                rte_eth_dev_probing_finish(eth_dev);
                dpaa2_valid_dev++;
                return 0;
-- 
2.25.1