Skip to content

Commit 0a8d5c3

Browse files
committed
UCT/IB/MLX5: fix purge for handler ok path
1 parent b27def8 commit 0a8d5c3

1 file changed

Lines changed: 2 additions & 3 deletions

File tree

src/uct/ib/mlx5/rc/rc_mlx5_iface.c

Lines changed: 2 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -222,9 +222,7 @@ void uct_rc_mlx5_iface_handle_failure(uct_ib_iface_t *ib_iface, void *arg,
222222

223223
uct_ib_mlx5_completion_with_err(ib_iface, arg, &ep->tx.wq, log_lvl);
224224

225-
if (status == UCS_OK) {
226-
uct_rc_txqp_purge_outstanding(iface, &ep->super.txqp, ep_status, pi, 0);
227-
} else if (status == UCS_INPROGRESS) {
225+
if (status == UCS_INPROGRESS) {
228226
ep->flags |= UCT_RC_MLX5_EP_FLAG_NO_COMPLETIONS;
229227
ep->tx.wq.ft_ci = ep->tx.wq.prev_sw_pi -
230228
(ep->tx.wq.bb_max -
@@ -235,6 +233,7 @@ void uct_rc_mlx5_iface_handle_failure(uct_ib_iface_t *ib_iface, void *arg,
235233

236234
out_update_tx_res:
237235
if (!(ep->flags & UCT_RC_MLX5_EP_FLAG_NO_COMPLETIONS)) {
236+
uct_rc_txqp_purge_outstanding(iface, &ep->super.txqp, ep_status, pi, 0);
238237
uct_rc_mlx5_ep_update_tx_qp_res(ep, pi);
239238
}
240239

0 commit comments

Comments
 (0)