net/mlx5: report imissed statistics
The imissed counters (number of packets dropped because the queues were full) were actually reported through xstats as "rx_out_of_buffer" but was not reported through stats. Following a recent discussion on the ML, as there is no way to tell the user if a counter is implemented or not, this should be considered a bug. For example, user looking at imissed will think the packets are lost before reaching the device. Signed-off-by: Tom Barbette <barbette@kth.se> Acked-by: Shahaf Shuler <shahafs@mellanox.com>
This commit is contained in:
parent
8eb9f9f025
commit
ce9494d76c
@ -172,7 +172,7 @@ Statistics
|
||||
|
||||
MLX5 supports various of methods to report statistics:
|
||||
|
||||
Port statistics can be queried using ``rte_eth_stats_get()``. The port statistics are through SW only and counts the number of packets received or sent successfully by the PMD.
|
||||
Port statistics can be queried using ``rte_eth_stats_get()``. The received and sent statistics are through SW only and counts the number of packets received or sent successfully by the PMD. The imissed counter is the amount of packets that could not be delivered to SW because a queue was full. Packets not received due to congestion in the bus or on the NIC can be queried via the rx_discards_phy xstats counter.
|
||||
|
||||
Extended statistics can be queried using ``rte_eth_xstats_get()``. The extended statistics expose a wider set of counters counted by the device. The extended port statistics counts the number of packets received or sent successfully by the port. As Mellanox NICs are using the :ref:`Bifurcated Linux Driver <linux_gsg_linux_drivers>` those counters counts also packet received or sent by the Linux kernel. The counters with ``_phy`` suffix counts the total events on the physical port, therefore not valid for VF.
|
||||
|
||||
|
@ -91,6 +91,11 @@ struct mlx5_xstats_ctrl {
|
||||
struct mlx5_counter_ctrl info[MLX5_MAX_XSTATS];
|
||||
};
|
||||
|
||||
struct mlx5_stats_ctrl {
|
||||
/* Base for imissed counter. */
|
||||
uint64_t imissed_base;
|
||||
};
|
||||
|
||||
/* Flow list . */
|
||||
TAILQ_HEAD(mlx5_flows, rte_flow);
|
||||
|
||||
@ -224,6 +229,7 @@ struct priv {
|
||||
LIST_HEAD(encap_decap, mlx5_flow_dv_encap_decap_resource) encaps_decaps;
|
||||
uint32_t link_speed_capa; /* Link speed capabilities. */
|
||||
struct mlx5_xstats_ctrl xstats_ctrl; /* Extended stats control. */
|
||||
struct mlx5_stats_ctrl stats_ctrl; /* Stats control. */
|
||||
int primary_socket; /* Unix socket for primary process. */
|
||||
void *uar_base; /* Reserved address space for UAR mapping */
|
||||
struct rte_intr_handle intr_handle_socket; /* Interrupt handler. */
|
||||
@ -316,7 +322,7 @@ void mlx5_allmulticast_disable(struct rte_eth_dev *dev);
|
||||
|
||||
/* mlx5_stats.c */
|
||||
|
||||
void mlx5_xstats_init(struct rte_eth_dev *dev);
|
||||
void mlx5_stats_init(struct rte_eth_dev *dev);
|
||||
int mlx5_stats_get(struct rte_eth_dev *dev, struct rte_eth_stats *stats);
|
||||
void mlx5_stats_reset(struct rte_eth_dev *dev);
|
||||
int mlx5_xstats_get(struct rte_eth_dev *dev, struct rte_eth_xstat *stats,
|
||||
|
@ -99,6 +99,14 @@ static const struct mlx5_counter_ctrl mlx5_counters_init[] = {
|
||||
.dpdk_name = "rx_packets_phy",
|
||||
.ctr_name = "rx_packets_phy",
|
||||
},
|
||||
{
|
||||
.dpdk_name = "tx_discards_phy",
|
||||
.ctr_name = "tx_discards_phy",
|
||||
},
|
||||
{
|
||||
.dpdk_name = "rx_discards_phy",
|
||||
.ctr_name = "rx_discards_phy",
|
||||
},
|
||||
{
|
||||
.dpdk_name = "tx_bytes_phy",
|
||||
.ctr_name = "tx_bytes_phy",
|
||||
@ -128,6 +136,24 @@ static const struct mlx5_counter_ctrl mlx5_counters_init[] = {
|
||||
|
||||
static const unsigned int xstats_n = RTE_DIM(mlx5_counters_init);
|
||||
|
||||
static inline void
|
||||
mlx5_read_ib_stat(struct priv *priv, const char *ctr_name, uint64_t *stat)
|
||||
{
|
||||
FILE *file;
|
||||
MKSTR(path, "%s/ports/1/hw_counters/%s",
|
||||
priv->ibdev_path,
|
||||
ctr_name);
|
||||
|
||||
file = fopen(path, "rb");
|
||||
if (file) {
|
||||
int n = fscanf(file, "%" SCNu64, stat);
|
||||
|
||||
fclose(file);
|
||||
if (n != 1)
|
||||
stat = 0;
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* Read device counters table.
|
||||
*
|
||||
@ -164,19 +190,8 @@ mlx5_read_dev_counters(struct rte_eth_dev *dev, uint64_t *stats)
|
||||
}
|
||||
for (i = 0; i != xstats_ctrl->mlx5_stats_n; ++i) {
|
||||
if (xstats_ctrl->info[i].ib) {
|
||||
FILE *file;
|
||||
MKSTR(path, "%s/ports/1/hw_counters/%s",
|
||||
priv->ibdev_path,
|
||||
xstats_ctrl->info[i].ctr_name);
|
||||
|
||||
file = fopen(path, "rb");
|
||||
if (file) {
|
||||
int n = fscanf(file, "%" SCNu64, &stats[i]);
|
||||
|
||||
fclose(file);
|
||||
if (n != 1)
|
||||
stats[i] = 0;
|
||||
}
|
||||
mlx5_read_ib_stat(priv, xstats_ctrl->info[i].ctr_name,
|
||||
&stats[i]);
|
||||
} else {
|
||||
stats[i] = (uint64_t)
|
||||
et_stats->data[xstats_ctrl->dev_table_idx[i]];
|
||||
@ -219,10 +234,11 @@ mlx5_ethtool_get_stats_n(struct rte_eth_dev *dev) {
|
||||
* Pointer to Ethernet device.
|
||||
*/
|
||||
void
|
||||
mlx5_xstats_init(struct rte_eth_dev *dev)
|
||||
mlx5_stats_init(struct rte_eth_dev *dev)
|
||||
{
|
||||
struct priv *priv = dev->data->dev_private;
|
||||
struct mlx5_xstats_ctrl *xstats_ctrl = &priv->xstats_ctrl;
|
||||
struct mlx5_stats_ctrl *stats_ctrl = &priv->stats_ctrl;
|
||||
unsigned int i;
|
||||
unsigned int j;
|
||||
struct ifreq ifr;
|
||||
@ -290,6 +306,7 @@ mlx5_xstats_init(struct rte_eth_dev *dev)
|
||||
if (ret)
|
||||
DRV_LOG(ERR, "port %u cannot read device counters: %s",
|
||||
dev->data->port_id, strerror(rte_errno));
|
||||
mlx5_read_ib_stat(priv, "out_of_buffer", &stats_ctrl->imissed_base);
|
||||
free:
|
||||
rte_free(strings);
|
||||
}
|
||||
@ -326,7 +343,7 @@ mlx5_xstats_get(struct rte_eth_dev *dev, struct rte_eth_xstat *stats,
|
||||
if (stats_n < 0)
|
||||
return stats_n;
|
||||
if (xstats_ctrl->stats_n != stats_n)
|
||||
mlx5_xstats_init(dev);
|
||||
mlx5_stats_init(dev);
|
||||
ret = mlx5_read_dev_counters(dev, counters);
|
||||
if (ret)
|
||||
return ret;
|
||||
@ -400,6 +417,8 @@ mlx5_stats_get(struct rte_eth_dev *dev, struct rte_eth_stats *stats)
|
||||
#endif
|
||||
tmp.oerrors += txq->stats.oerrors;
|
||||
}
|
||||
mlx5_read_ib_stat(priv, "out_of_buffer", &tmp.imissed);
|
||||
tmp.imissed -= priv->stats_ctrl.imissed_base;
|
||||
#ifndef MLX5_PMD_SOFT_COUNTERS
|
||||
/* FIXME: retrieve and add hardware counters. */
|
||||
#endif
|
||||
@ -417,6 +436,7 @@ void
|
||||
mlx5_stats_reset(struct rte_eth_dev *dev)
|
||||
{
|
||||
struct priv *priv = dev->data->dev_private;
|
||||
struct mlx5_stats_ctrl *stats_ctrl = &priv->stats_ctrl;
|
||||
unsigned int i;
|
||||
unsigned int idx;
|
||||
|
||||
@ -434,6 +454,7 @@ mlx5_stats_reset(struct rte_eth_dev *dev)
|
||||
(*priv->txqs)[i]->stats =
|
||||
(struct mlx5_txq_stats){ .idx = idx };
|
||||
}
|
||||
mlx5_read_ib_stat(priv, "out_of_buffer", &stats_ctrl->imissed_base);
|
||||
#ifndef MLX5_PMD_SOFT_COUNTERS
|
||||
/* FIXME: reset hardware counters. */
|
||||
#endif
|
||||
@ -463,7 +484,7 @@ mlx5_xstats_reset(struct rte_eth_dev *dev)
|
||||
return;
|
||||
}
|
||||
if (xstats_ctrl->stats_n != stats_n)
|
||||
mlx5_xstats_init(dev);
|
||||
mlx5_stats_init(dev);
|
||||
ret = mlx5_read_dev_counters(dev, counters);
|
||||
if (ret) {
|
||||
DRV_LOG(ERR, "port %u cannot read device counters: %s",
|
||||
|
@ -181,7 +181,7 @@ mlx5_dev_start(struct rte_eth_dev *dev)
|
||||
dev->data->port_id);
|
||||
goto error;
|
||||
}
|
||||
mlx5_xstats_init(dev);
|
||||
mlx5_stats_init(dev);
|
||||
ret = mlx5_traffic_enable(dev);
|
||||
if (ret) {
|
||||
DRV_LOG(DEBUG, "port %u failed to set defaults flows",
|
||||
|
Loading…
Reference in New Issue
Block a user