From: Long Wu <long...@corigine.com>

The 'ipackets'/'opackets' are used to record the number
of packets on represetor port received/sent. But the
code does not consider concurrent calculation of
'ipackets'/'opackets'. If multiple queues are calculated
'ipackets'/'opackets' simultaneously, it will result in
incorrect results.
The previous logic has recorded the number of packets on
each queue, therefore driver only needs to add the data of
all queues to obtain the data of the representor port.

Based on this, modify code to fix the issue.

Fixes: 636e133ec891 ("net/nfp: update Tx and Rx for multiple PF")
Fixes: 82a2c286f35a ("net/nfp: support xstats for flower firmware")
Cc: peng.zh...@corigine.com
Cc: chaoyong...@corigine.com
Cc: sta...@dpdk.org

Signed-off-by: Long Wu <long...@corigine.com>
---
 drivers/net/nfp/flower/nfp_flower.c            |  2 --
 .../net/nfp/flower/nfp_flower_representor.c    | 18 ++++++++++++++++--
 2 files changed, 16 insertions(+), 4 deletions(-)

diff --git a/drivers/net/nfp/flower/nfp_flower.c 
b/drivers/net/nfp/flower/nfp_flower.c
index f087d0dfdc..804ad494d5 100644
--- a/drivers/net/nfp/flower/nfp_flower.c
+++ b/drivers/net/nfp/flower/nfp_flower.c
@@ -238,7 +238,6 @@ nfp_flower_multiple_pf_recv_pkts(void *rx_queue,
                for (i = 0; i < recv; i++)
                        data_len += rx_pkts[i]->data_len;
 
-               repr->repr_stats.ipackets += recv;
                repr->repr_stats.q_ipackets[rxq->qidx] += recv;
                repr->repr_stats.q_ibytes[rxq->qidx] += data_len;
        }
@@ -277,7 +276,6 @@ nfp_flower_multiple_pf_xmit_pkts(void *tx_queue,
                for (i = 0; i < sent; i++)
                        data_len += tx_pkts[i]->data_len;
 
-               repr->repr_stats.opackets += sent;
                repr->repr_stats.q_opackets[txq->qidx] += sent;
                repr->repr_stats.q_obytes[txq->qidx] += data_len;
        }
diff --git a/drivers/net/nfp/flower/nfp_flower_representor.c 
b/drivers/net/nfp/flower/nfp_flower_representor.c
index 9601aa5f96..e377d45e53 100644
--- a/drivers/net/nfp/flower/nfp_flower_representor.c
+++ b/drivers/net/nfp/flower/nfp_flower_representor.c
@@ -315,9 +315,25 @@ static int
 nfp_flower_repr_stats_get(struct rte_eth_dev *ethdev,
                struct rte_eth_stats *stats)
 {
+       uint16_t i;
        struct nfp_flower_representor *repr;
 
        repr = ethdev->data->dev_private;
+
+       repr->repr_stats.ipackets = 0;
+       repr->repr_stats.ibytes = 0;
+       for (i = 0; i < ethdev->data->nb_rx_queues; i++) {
+               repr->repr_stats.ipackets += repr->repr_stats.q_ipackets[i];
+               repr->repr_stats.ibytes += repr->repr_stats.q_ibytes[i];
+       }
+
+       repr->repr_stats.opackets = 0;
+       repr->repr_stats.obytes = 0;
+       for (i = 0; i < ethdev->data->nb_tx_queues; i++) {
+               repr->repr_stats.opackets += repr->repr_stats.q_opackets[i];
+               repr->repr_stats.obytes += repr->repr_stats.q_obytes[i];
+       }
+
        rte_memcpy(stats, &repr->repr_stats, sizeof(struct rte_eth_stats));
 
        return 0;
@@ -385,7 +401,6 @@ nfp_flower_repr_rx_burst(void *rx_queue,
                for (i = 0; i < total_dequeue; i++)
                        data_len += rx_pkts[i]->data_len;
 
-               repr->repr_stats.ipackets += total_dequeue;
                repr->repr_stats.q_ipackets[rxq->qidx] += total_dequeue;
                repr->repr_stats.q_ibytes[rxq->qidx] += data_len;
        }
@@ -434,7 +449,6 @@ nfp_flower_repr_tx_burst(void *tx_queue,
                for (i = 0; i < sent; i++)
                        data_len += tx_pkts[i]->data_len;
 
-               repr->repr_stats.opackets += sent;
                repr->repr_stats.q_opackets[txq->qidx] += sent;
                repr->repr_stats.q_obytes[txq->qidx] += data_len;
        }
-- 
2.43.5

Reply via email to