RDMA/cxgb4: Abort connections that receive unexpected streaming mode data

[cascardo/linux.git] / drivers / infiniband / hw / cxgb4 / cm.c

diff --git a/drivers/infiniband/hw/cxgb4/cm.c b/drivers/infiniband/hw/cxgb4/cm.c
index c13745c..9cab6a6 100644 (file)
--- a/drivers/infiniband/hw/cxgb4/cm.c
+++ b/drivers/infiniband/hw/cxgb4/cm.c
@@ -1391,30 +1391,31 @@ static int rx_data(struct c4iw_dev *dev, struct sk_buff *skb)
        skb_pull(skb, sizeof(*hdr));
        skb_trim(skb, dlen);
 
-       ep->rcv_seq += dlen;
-       BUG_ON(ep->rcv_seq != (ntohl(hdr->seq) + dlen));
-
        /* update RX credits */
        update_rx_credits(ep, dlen);
 
        switch (state_read(&ep->com)) {
        case MPA_REQ_SENT:
+               ep->rcv_seq += dlen;
                process_mpa_reply(ep, skb);
                break;
        case MPA_REQ_WAIT:
+               ep->rcv_seq += dlen;
                process_mpa_request(ep, skb);
                break;
-       case MPA_REP_SENT:
-               break;
        default:
                pr_err("%s Unexpected streaming data." \
                       " ep %p state %d tid %u status %d\n",
                       __func__, ep, state_read(&ep->com), ep->hwtid, status);
 
-               /*
-                * The ep will timeout and inform the ULP of the failure.
-                * See ep_timeout().
-                */
+               if (ep->com.qp) {
+                       struct c4iw_qp_attributes attrs;
+
+                       attrs.next_state = C4IW_QP_STATE_ERROR;
+                       c4iw_modify_qp(ep->com.qp->rhp, ep->com.qp,
+                                      C4IW_QP_ATTR_NEXT_STATE, &attrs, 1);
+               }
+               c4iw_ep_disconnect(ep, 1, GFP_KERNEL);
                break;
        }
        return 0;