|
@@ -813,18 +813,17 @@ static enum resp_states execute(struct rxe_qp *qp, struct rxe_pkt_info *pkt)
|
|
|
WARN_ON_ONCE(1);
|
|
|
}
|
|
|
|
|
|
- /* We successfully processed this new request. */
|
|
|
- qp->resp.msn++;
|
|
|
-
|
|
|
/* next expected psn, read handles this separately */
|
|
|
qp->resp.psn = (pkt->psn + 1) & BTH_PSN_MASK;
|
|
|
|
|
|
qp->resp.opcode = pkt->opcode;
|
|
|
qp->resp.status = IB_WC_SUCCESS;
|
|
|
|
|
|
- if (pkt->mask & RXE_COMP_MASK)
|
|
|
+ if (pkt->mask & RXE_COMP_MASK) {
|
|
|
+ /* We successfully processed this new request. */
|
|
|
+ qp->resp.msn++;
|
|
|
return RESPST_COMPLETE;
|
|
|
- else if (qp_type(qp) == IB_QPT_RC)
|
|
|
+ } else if (qp_type(qp) == IB_QPT_RC)
|
|
|
return RESPST_ACKNOWLEDGE;
|
|
|
else
|
|
|
return RESPST_CLEANUP;
|