Commit b0ffeb53 authored by Slava Shwartsman's avatar Slava Shwartsman Committed by Doug Ledford

IB/mlx5: Fix iteration overrun in GSI qps

Number of outstanding_pi may overflow and as a result may indicate that
there are no elements in the queue. The effect of doing this is that the
MAD layer will get stuck waiting for completions. The MAD layer will
think that the QP is full - because it didn't receive these completions.

This fix changes it so the outstanding_pi number is increased
with 32-bit wraparound and is not limited to max_send_wr so
that the difference between outstanding_pi and outstanding_ci will
really indicate the number of outstanding completions.

Cc: Stable <stable@vger.kernel.org>
Fixes: ea6dc203 ('IB/mlx5: Reorder GSI completions')
Signed-off-by: default avatarSlava Shwartsman <slavash@mellanox.com>
Signed-off-by: default avatarLeon Romanovsky <leon@kernel.org>
Reviewed-by: default avatarHaggai Eran <haggaie@mellanox.com>
Reviewed-by: default avatarSagi Grimberg <sagi@grimberg.me>
Signed-off-by: default avatarDoug Ledford <dledford@redhat.com>
parent 61961500
...@@ -69,15 +69,6 @@ static bool mlx5_ib_deth_sqpn_cap(struct mlx5_ib_dev *dev) ...@@ -69,15 +69,6 @@ static bool mlx5_ib_deth_sqpn_cap(struct mlx5_ib_dev *dev)
return MLX5_CAP_GEN(dev->mdev, set_deth_sqpn); return MLX5_CAP_GEN(dev->mdev, set_deth_sqpn);
} }
static u32 next_outstanding(struct mlx5_ib_gsi_qp *gsi, u32 index)
{
return ++index % gsi->cap.max_send_wr;
}
#define for_each_outstanding_wr(gsi, index) \
for (index = gsi->outstanding_ci; index != gsi->outstanding_pi; \
index = next_outstanding(gsi, index))
/* Call with gsi->lock locked */ /* Call with gsi->lock locked */
static void generate_completions(struct mlx5_ib_gsi_qp *gsi) static void generate_completions(struct mlx5_ib_gsi_qp *gsi)
{ {
...@@ -85,8 +76,9 @@ static void generate_completions(struct mlx5_ib_gsi_qp *gsi) ...@@ -85,8 +76,9 @@ static void generate_completions(struct mlx5_ib_gsi_qp *gsi)
struct mlx5_ib_gsi_wr *wr; struct mlx5_ib_gsi_wr *wr;
u32 index; u32 index;
for_each_outstanding_wr(gsi, index) { for (index = gsi->outstanding_ci; index != gsi->outstanding_pi;
wr = &gsi->outstanding_wrs[index]; index++) {
wr = &gsi->outstanding_wrs[index % gsi->cap.max_send_wr];
if (!wr->completed) if (!wr->completed)
break; break;
...@@ -430,8 +422,9 @@ static int mlx5_ib_add_outstanding_wr(struct mlx5_ib_gsi_qp *gsi, ...@@ -430,8 +422,9 @@ static int mlx5_ib_add_outstanding_wr(struct mlx5_ib_gsi_qp *gsi,
return -ENOMEM; return -ENOMEM;
} }
gsi_wr = &gsi->outstanding_wrs[gsi->outstanding_pi]; gsi_wr = &gsi->outstanding_wrs[gsi->outstanding_pi %
gsi->outstanding_pi = next_outstanding(gsi, gsi->outstanding_pi); gsi->cap.max_send_wr];
gsi->outstanding_pi++;
if (!wc) { if (!wc) {
memset(&gsi_wr->wc, 0, sizeof(gsi_wr->wc)); memset(&gsi_wr->wc, 0, sizeof(gsi_wr->wc));
......
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