Commit fc42d0de authored by Aya Levin's avatar Aya Levin Committed by Saeed Mahameed

net/mlx5e: Add helper to get RQ WQE's head

Add helper which retrieves the RQ WQE's head. Use this helper in RX
reporter diagnose callback.
Signed-off-by: default avatarAya Levin <ayal@mellanox.com>
Signed-off-by: default avatarSaeed Mahameed <saeedm@mellanox.com>
parent 5d95c816
...@@ -181,7 +181,6 @@ static int mlx5e_rx_reporter_build_diagnose_output(struct mlx5e_rq *rq, ...@@ -181,7 +181,6 @@ static int mlx5e_rx_reporter_build_diagnose_output(struct mlx5e_rq *rq,
struct devlink_fmsg *fmsg) struct devlink_fmsg *fmsg)
{ {
struct mlx5e_priv *priv = rq->channel->priv; struct mlx5e_priv *priv = rq->channel->priv;
struct mlx5e_params *params;
struct mlx5e_icosq *icosq; struct mlx5e_icosq *icosq;
u8 icosq_hw_state; u8 icosq_hw_state;
int wqes_sz; int wqes_sz;
...@@ -189,7 +188,6 @@ static int mlx5e_rx_reporter_build_diagnose_output(struct mlx5e_rq *rq, ...@@ -189,7 +188,6 @@ static int mlx5e_rx_reporter_build_diagnose_output(struct mlx5e_rq *rq,
u16 wq_head; u16 wq_head;
int err; int err;
params = &priv->channels.params;
icosq = &rq->channel->icosq; icosq = &rq->channel->icosq;
err = mlx5e_query_rq_state(priv->mdev, rq->rqn, &hw_state); err = mlx5e_query_rq_state(priv->mdev, rq->rqn, &hw_state);
if (err) if (err)
...@@ -200,8 +198,7 @@ static int mlx5e_rx_reporter_build_diagnose_output(struct mlx5e_rq *rq, ...@@ -200,8 +198,7 @@ static int mlx5e_rx_reporter_build_diagnose_output(struct mlx5e_rq *rq,
return err; return err;
wqes_sz = mlx5e_rqwq_get_cur_sz(rq); wqes_sz = mlx5e_rqwq_get_cur_sz(rq);
wq_head = params->rq_wq_type == MLX5_WQ_TYPE_LINKED_LIST_STRIDING_RQ ? wq_head = mlx5e_rqwq_get_head(rq);
rq->mpwqe.wq.head : mlx5_wq_cyc_get_head(&rq->wqe.wq);
err = devlink_fmsg_obj_nest_start(fmsg); err = devlink_fmsg_obj_nest_start(fmsg);
if (err) if (err)
......
...@@ -304,6 +304,16 @@ static inline u32 mlx5e_rqwq_get_cur_sz(struct mlx5e_rq *rq) ...@@ -304,6 +304,16 @@ static inline u32 mlx5e_rqwq_get_cur_sz(struct mlx5e_rq *rq)
} }
} }
static inline u16 mlx5e_rqwq_get_head(struct mlx5e_rq *rq)
{
switch (rq->wq_type) {
case MLX5_WQ_TYPE_LINKED_LIST_STRIDING_RQ:
return mlx5_wq_ll_get_head(&rq->mpwqe.wq);
default:
return mlx5_wq_cyc_get_head(&rq->wqe.wq);
}
}
/* SW parser related functions */ /* SW parser related functions */
struct mlx5e_swp_spec { struct mlx5e_swp_spec {
......
...@@ -290,4 +290,8 @@ static inline void mlx5_wq_ll_update_db_record(struct mlx5_wq_ll *wq) ...@@ -290,4 +290,8 @@ static inline void mlx5_wq_ll_update_db_record(struct mlx5_wq_ll *wq)
*wq->db = cpu_to_be32(wq->wqe_ctr); *wq->db = cpu_to_be32(wq->wqe_ctr);
} }
static inline u16 mlx5_wq_ll_get_head(struct mlx5_wq_ll *wq)
{
return wq->head;
}
#endif /* __MLX5_WQ_H__ */ #endif /* __MLX5_WQ_H__ */
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment