ulp/ipoib/ipoib_cm.c

88 static int ipoib_cm_post_receive_srq(struct ipoib_dev_priv *priv, int id)
96 	rx_req = (struct ipoib_rx_buf *)&priv->cm.srq_ring[id];
103 	priv->cm.rx_wr.wr_id = id | IPOIB_OP_CM | IPOIB_OP_RECV;
107 		ipoib_warn(priv, "post srq failed for buf %d (%d)\n", id, ret);
109 		m_freem(priv->cm.srq_ring[id].mb);
110 		priv->cm.srq_ring[id].mb = NULL;
119 					struct ib_sge *sge, int id)
127 	rx_req = (struct ipoib_rx_buf *)&rx->rx_ring[id];
134 	wr->wr_id = id | IPOIB_OP_CM | IPOIB_OP_RECV;
138 		ipoib_warn(priv, "post recv failed for buf %d (%d)\n", id, ret);
140 		m_freem(rx->rx_ring[id].mb);
141 		rx->rx_ring[id].mb = NULL;
401 	p->id = cm_id;
486 	ipoib_dbg_data(priv, "cm recv completion: id %d, status: %d\n",
494 			if (priv->cm.id != NULL)
675 	ipoib_dbg_data(priv, "cm send completion: id %d, status: %d\n",
732 	priv->cm.id = ib_create_cm_id(priv->ca, ipoib_cm_rx_handler, priv);
733 	if (IS_ERR(priv->cm.id)) {
735 		ret = PTR_ERR(priv->cm.id);
739 	ret = ib_cm_listen(priv->cm.id, cpu_to_be64(IPOIB_CM_IETF_ID | priv->qp->qp_num),
750 	ib_destroy_cm_id(priv->cm.id);
752 	priv->cm.id = NULL;
766 		ib_destroy_cm_id(rx->id);
784 	if (!IPOIB_CM_SUPPORTED(IF_LLADDR(priv->dev)) || !priv->cm.id)
787 	ib_destroy_cm_id(priv->cm.id);
788 	priv->cm.id = NULL;
932 			     struct ib_cm_id *id, struct ib_qp *qp,
966 	return ib_send_cm_req(id, &req);
1014 	p->id = ib_create_cm_id(priv->ca, ipoib_cm_tx_handler, p);
1015 	if (IS_ERR(p->id)) {
1016 		ret = PTR_ERR(p->id);
1017 		ipoib_warn(priv, "failed to create tx cm id: %d\n", ret);
1021 	ret = ipoib_cm_modify_tx_init(p->priv, p->id,  p->qp);
1027 	ret = ipoib_cm_send_req(p->priv, p->id, p->qp, qpn, pathrec);
1040 	ib_destroy_cm_id(p->id);
1042 	p->id = NULL;
1064 	if (p->id)
1065 		ib_destroy_cm_id(p->id);