[dpdk-dev] [PATCH v3 2/2] app/testpmd: add mempool bulk get for txonly mode

[Pavan Nikhilesh Bhagavatula]

From: Pavan Nikhilesh <pbhagavat...@marvell.com>

Use mempool bulk get ops to alloc burst of packets and process them.
If bulk get fails fallback to rte_mbuf_raw_alloc.

Tested-by: Yingya Han <yingyax....@intel.com>
Suggested-by: Andrew Rybchenko <arybche...@solarflare.com>
Signed-off-by: Pavan Nikhilesh <pbhagavat...@marvell.com>
---
 app/test-pmd/txonly.c | 37 ++++++++++++++++++++++++++-----------
 1 file changed, 26 insertions(+), 11 deletions(-)

diff --git a/app/test-pmd/txonly.c b/app/test-pmd/txonly.c
index 5610e0e42..3ca13e622 100644
--- a/app/test-pmd/txonly.c
+++ b/app/test-pmd/txonly.c
@@ -249,18 +249,33 @@ pkt_burst_transmit(struct fwd_stream *fs)
        ether_addr_copy(&ports[fs->tx_port].eth_addr, &eth_hdr.s_addr);
        eth_hdr.ether_type = rte_cpu_to_be_16(ETHER_TYPE_IPv4);
 
-       for (nb_pkt = 0; nb_pkt < nb_pkt_per_burst; nb_pkt++) {
-               pkt = rte_mbuf_raw_alloc(mbp);
-               if (pkt == NULL)
-                       break;
-               if (unlikely(!pkt_burst_prepare(pkt, mbp,
-                                               &eth_hdr, vlan_tci,
-                                               vlan_tci_outer,
-                                               ol_flags))) {
-                       rte_mempool_put(mbp, pkt);
-                       break;
+       if (rte_mempool_get_bulk(mbp, (void **)pkts_burst,
+                               nb_pkt_per_burst) == 0) {
+               for (nb_pkt = 0; nb_pkt < nb_pkt_per_burst; nb_pkt++) {
+                       if (unlikely(!pkt_burst_prepare(pkts_burst[nb_pkt], mbp,
+                                                       &eth_hdr, vlan_tci,
+                                                       vlan_tci_outer,
+                                                       ol_flags))) {
+                               rte_mempool_put_bulk(mbp,
+                                               (void **)&pkts_burst[nb_pkt],
+                                               nb_pkt_per_burst - nb_pkt);
+                               break;
+                       }
+               }
+       } else {
+               for (nb_pkt = 0; nb_pkt < nb_pkt_per_burst; nb_pkt++) {
+                       pkt = rte_mbuf_raw_alloc(mbp);
+                       if (pkt == NULL)
+                               break;
+                       if (unlikely(!pkt_burst_prepare(pkt, mbp,
+                                                       &eth_hdr, vlan_tci,
+                                                       vlan_tci_outer,
+                                                       ol_flags))) {
+                               rte_mempool_put(mbp, pkt);
+                               break;
+                       }
+                       pkts_burst[nb_pkt] = pkt;
                }
-               pkts_burst[nb_pkt] = pkt;
        }
 
        if (nb_pkt == 0)
-- 
2.20.1