|
@@ -594,8 +594,10 @@ int rxe_requester(void *arg)
|
|
rxe_add_ref(qp);
|
|
rxe_add_ref(qp);
|
|
|
|
|
|
next_wqe:
|
|
next_wqe:
|
|
- if (unlikely(!qp->valid))
|
|
|
|
|
|
+ if (unlikely(!qp->valid)) {
|
|
|
|
+ rxe_drain_req_pkts(qp, true);
|
|
goto exit;
|
|
goto exit;
|
|
|
|
+ }
|
|
|
|
|
|
if (unlikely(qp->req.state == QP_STATE_ERROR)) {
|
|
if (unlikely(qp->req.state == QP_STATE_ERROR)) {
|
|
rxe_drain_req_pkts(qp, true);
|
|
rxe_drain_req_pkts(qp, true);
|