[dpdk-dev] [PATCH v2 15/15] app/testpmd: support shared Rx queue for ieee1588 fwd

[Xueming Li]

From: Xiaoyu Min <jack...@nvidia.com>

Add support of shared rxq.
If shared rxq is enabled, filter packet by stream according
to mbuf->port value and then fwd it in stream basis (as before).

If shared rxq is not enabled, just fwd it as usual in stream basis.

Signed-off-by: Xiaoyu Min <jack...@nvidia.com>
---
 app/test-pmd/ieee1588fwd.c | 30 ++++++++++++++++++++----------
 1 file changed, 20 insertions(+), 10 deletions(-)

diff --git a/app/test-pmd/ieee1588fwd.c b/app/test-pmd/ieee1588fwd.c
index 034f238c34..dc6bf0e39d 100644
--- a/app/test-pmd/ieee1588fwd.c
+++ b/app/test-pmd/ieee1588fwd.c
@@ -90,23 +90,17 @@ port_ieee1588_tx_timestamp_check(portid_t pi)
 }
 
 static void
-ieee1588_packet_fwd(struct fwd_stream *fs)
+ieee1588_fwd_stream(struct fwd_stream *fs, uint16_t nb_rx,
+               struct rte_mbuf **pkt)
 {
-       struct rte_mbuf  *mb;
+       struct rte_mbuf *mb = (*pkt);
        struct rte_ether_hdr *eth_hdr;
        struct rte_ether_addr addr;
        struct ptpv2_msg *ptp_hdr;
        uint16_t eth_type;
        uint32_t timesync_index;
 
-       /*
-        * Receive 1 packet at a time.
-        */
-       if (rte_eth_rx_burst(fs->rx_port, fs->rx_queue, &mb, 1) == 0)
-               return;
-
-       fs->rx_packets += 1;
-
+       RTE_SET_USED(nb_rx);
        /*
         * Check that the received packet is a PTP packet that was detected
         * by the hardware.
@@ -198,6 +192,22 @@ ieee1588_packet_fwd(struct fwd_stream *fs)
        port_ieee1588_tx_timestamp_check(fs->rx_port);
 }
 
+/*
+ * Wrapper of real fwd ingine.
+ */
+static void
+ieee1588_packet_fwd(struct fwd_stream *fs)
+{
+       struct rte_mbuf *mb;
+
+       if (rte_eth_rx_burst(fs->rx_port, fs->rx_queue, &mb, 1) == 0)
+               return;
+       if (unlikely(rxq_share > 0))
+               forward_shared_rxq(fs, 1, &mb, ieee1588_fwd_stream);
+       else
+               ieee1588_fwd_stream(fs, 1, &mb);
+}
+
 static void
 port_ieee1588_fwd_begin(portid_t pi)
 {
-- 
2.25.1