1 /* SPDX-License-Identifier: BSD-3-Clause
2 * Copyright 2015 6WIND S.A.
3 * Copyright 2015 Mellanox Technologies, Ltd
11 #include <rte_ethdev_driver.h>
12 #include <rte_common.h>
13 #include <rte_malloc.h>
15 #include <mlx5_common.h>
17 #include "mlx5_defs.h"
19 #include "mlx5_rxtx.h"
20 #include "mlx5_malloc.h"
23 * DPDK callback to get extended device statistics.
26 * Pointer to Ethernet device.
28 * Pointer to rte extended stats table.
30 * The size of the stats table.
33 * Number of extended stats on success and stats is filled,
34 * negative on error and rte_errno is set.
37 mlx5_xstats_get(struct rte_eth_dev *dev, struct rte_eth_xstat *stats,
40 struct mlx5_priv *priv = dev->data->dev_private;
43 struct mlx5_xstats_ctrl *xstats_ctrl = &priv->xstats_ctrl;
44 uint16_t mlx5_stats_n = xstats_ctrl->mlx5_stats_n;
46 if (n >= mlx5_stats_n && stats) {
50 stats_n = mlx5_os_get_stats_n(dev);
53 if (xstats_ctrl->stats_n != stats_n)
54 mlx5_os_stats_init(dev);
55 ret = mlx5_os_read_dev_counters(dev, counters);
58 for (i = 0; i != mlx5_stats_n; ++i) {
60 if (xstats_ctrl->info[i].dev) {
62 uint64_t hw_stat = xstats_ctrl->hw_stats[i];
64 stats[i].value = (counters[i] -
65 xstats_ctrl->base[i]) &
67 wrap_n = hw_stat >> 32;
69 (hw_stat & (uint64_t)UINT32_MAX))
71 stats[i].value |= (wrap_n) << 32;
72 xstats_ctrl->hw_stats[i] = stats[i].value;
75 (counters[i] - xstats_ctrl->base[i]);
79 mlx5_stats_n = mlx5_txpp_xstats_get(dev, stats, n, mlx5_stats_n);
84 * DPDK callback to get device statistics.
87 * Pointer to Ethernet device structure.
89 * Stats structure output buffer.
92 * 0 on success and stats is filled, negative errno value otherwise and
96 mlx5_stats_get(struct rte_eth_dev *dev, struct rte_eth_stats *stats)
98 struct mlx5_priv *priv = dev->data->dev_private;
99 struct mlx5_stats_ctrl *stats_ctrl = &priv->stats_ctrl;
100 struct rte_eth_stats tmp;
106 memset(&tmp, 0, sizeof(tmp));
107 /* Add software counters. */
108 for (i = 0; (i != priv->rxqs_n); ++i) {
109 struct mlx5_rxq_data *rxq = (*priv->rxqs)[i];
114 if (idx < RTE_ETHDEV_QUEUE_STAT_CNTRS) {
115 #ifdef MLX5_PMD_SOFT_COUNTERS
116 tmp.q_ipackets[idx] += rxq->stats.ipackets;
117 tmp.q_ibytes[idx] += rxq->stats.ibytes;
119 tmp.q_errors[idx] += (rxq->stats.idropped +
120 rxq->stats.rx_nombuf);
122 #ifdef MLX5_PMD_SOFT_COUNTERS
123 tmp.ipackets += rxq->stats.ipackets;
124 tmp.ibytes += rxq->stats.ibytes;
126 tmp.ierrors += rxq->stats.idropped;
127 tmp.rx_nombuf += rxq->stats.rx_nombuf;
129 for (i = 0; (i != priv->txqs_n); ++i) {
130 struct mlx5_txq_data *txq = (*priv->txqs)[i];
135 if (idx < RTE_ETHDEV_QUEUE_STAT_CNTRS) {
136 #ifdef MLX5_PMD_SOFT_COUNTERS
137 tmp.q_opackets[idx] += txq->stats.opackets;
138 tmp.q_obytes[idx] += txq->stats.obytes;
141 #ifdef MLX5_PMD_SOFT_COUNTERS
142 tmp.opackets += txq->stats.opackets;
143 tmp.obytes += txq->stats.obytes;
145 tmp.oerrors += txq->stats.oerrors;
147 ret = mlx5_os_read_dev_stat(priv, "out_of_buffer", &tmp.imissed);
149 tmp.imissed = (tmp.imissed - stats_ctrl->imissed_base) &
150 (uint64_t)UINT32_MAX;
151 wrap_n = stats_ctrl->imissed >> 32;
152 if (tmp.imissed < (stats_ctrl->imissed & (uint64_t)UINT32_MAX))
154 tmp.imissed |= (wrap_n) << 32;
155 stats_ctrl->imissed = tmp.imissed;
157 tmp.imissed = stats_ctrl->imissed;
159 #ifndef MLX5_PMD_SOFT_COUNTERS
160 /* FIXME: retrieve and add hardware counters. */
167 * DPDK callback to clear device statistics.
170 * Pointer to Ethernet device structure.
173 * always 0 on success and stats is reset
176 mlx5_stats_reset(struct rte_eth_dev *dev)
178 struct mlx5_priv *priv = dev->data->dev_private;
179 struct mlx5_stats_ctrl *stats_ctrl = &priv->stats_ctrl;
182 for (i = 0; (i != priv->rxqs_n); ++i) {
183 if ((*priv->rxqs)[i] == NULL)
185 memset(&(*priv->rxqs)[i]->stats, 0,
186 sizeof(struct mlx5_rxq_stats));
188 for (i = 0; (i != priv->txqs_n); ++i) {
189 if ((*priv->txqs)[i] == NULL)
191 memset(&(*priv->txqs)[i]->stats, 0,
192 sizeof(struct mlx5_txq_stats));
194 mlx5_os_read_dev_stat(priv, "out_of_buffer", &stats_ctrl->imissed_base);
195 stats_ctrl->imissed = 0;
196 #ifndef MLX5_PMD_SOFT_COUNTERS
197 /* FIXME: reset hardware counters. */
204 * DPDK callback to clear device extended statistics.
207 * Pointer to Ethernet device structure.
210 * 0 on success and stats is reset, negative errno value otherwise and
214 mlx5_xstats_reset(struct rte_eth_dev *dev)
216 struct mlx5_priv *priv = dev->data->dev_private;
217 struct mlx5_xstats_ctrl *xstats_ctrl = &priv->xstats_ctrl;
223 stats_n = mlx5_os_get_stats_n(dev);
225 DRV_LOG(ERR, "port %u cannot get stats: %s", dev->data->port_id,
229 if (xstats_ctrl->stats_n != stats_n)
230 mlx5_os_stats_init(dev);
231 counters = mlx5_malloc(MLX5_MEM_SYS, sizeof(*counters) *
232 xstats_ctrl->mlx5_stats_n, 0,
235 DRV_LOG(WARNING, "port %u unable to allocate memory for xstats "
241 ret = mlx5_os_read_dev_counters(dev, counters);
243 DRV_LOG(ERR, "port %u cannot read device counters: %s",
244 dev->data->port_id, strerror(rte_errno));
248 for (i = 0; i != xstats_ctrl->mlx5_stats_n; ++i) {
249 xstats_ctrl->base[i] = counters[i];
250 xstats_ctrl->hw_stats[i] = 0;
252 mlx5_txpp_xstats_reset(dev);
258 * DPDK callback to retrieve names of extended device statistics
261 * Pointer to Ethernet device structure.
262 * @param[out] xstats_names
263 * Buffer to insert names into.
268 * Number of xstats names.
271 mlx5_xstats_get_names(struct rte_eth_dev *dev,
272 struct rte_eth_xstat_name *xstats_names, unsigned int n)
275 struct mlx5_priv *priv = dev->data->dev_private;
276 struct mlx5_xstats_ctrl *xstats_ctrl = &priv->xstats_ctrl;
277 unsigned int mlx5_xstats_n = xstats_ctrl->mlx5_stats_n;
279 if (n >= mlx5_xstats_n && xstats_names) {
280 for (i = 0; i != mlx5_xstats_n; ++i) {
281 strncpy(xstats_names[i].name,
282 xstats_ctrl->info[i].dpdk_name,
283 RTE_ETH_XSTATS_NAME_SIZE);
284 xstats_names[i].name[RTE_ETH_XSTATS_NAME_SIZE - 1] = 0;
287 mlx5_xstats_n = mlx5_txpp_xstats_get_names(dev, xstats_names,
289 return mlx5_xstats_n;