39 int ipoib_mcast_attach(struct ipoib_dev_priv *priv, u16 mlid, union ib_gid *mgid, int set_qkey)  in ipoib_mcast_attach()  argument
45 	if (ib_find_pkey(priv->ca, priv->port, priv->pkey, &pkey_index)) {  in ipoib_mcast_attach()
46 		clear_bit(IPOIB_PKEY_ASSIGNED, &priv->flags);  in ipoib_mcast_attach()
50 	set_bit(IPOIB_PKEY_ASSIGNED, &priv->flags);  in ipoib_mcast_attach()
59 		qp_attr->qkey = priv->qkey;  in ipoib_mcast_attach()
60 		ret = ib_modify_qp(priv->qp, qp_attr, IB_QP_QKEY);  in ipoib_mcast_attach()
62 			ipoib_warn(priv, "failed to modify QP, ret = %d\n", ret);  in ipoib_mcast_attach()
68 	ret = ib_attach_mcast(priv->qp, mgid, mlid);  in ipoib_mcast_attach()
70 		ipoib_warn(priv, "failed to attach to multicast group, ret = %d\n", ret);  in ipoib_mcast_attach()
77 int ipoib_init_qp(struct ipoib_dev_priv *priv)  in ipoib_init_qp()  argument
83 	if (!test_bit(IPOIB_PKEY_ASSIGNED, &priv->flags))  in ipoib_init_qp()
88 	qp_attr.port_num = priv->port;  in ipoib_init_qp()
89 	qp_attr.pkey_index = priv->pkey_index;  in ipoib_init_qp()
96 	ret = ib_modify_qp(priv->qp, &qp_attr, attr_mask);  in ipoib_init_qp()
98 		ipoib_warn(priv, "failed to modify QP to init, ret = %d\n", ret);  in ipoib_init_qp()
105 	ret = ib_modify_qp(priv->qp, &qp_attr, attr_mask);  in ipoib_init_qp()
107 		ipoib_warn(priv, "failed to modify QP to RTR, ret = %d\n", ret);  in ipoib_init_qp()
115 	ret = ib_modify_qp(priv->qp, &qp_attr, attr_mask);  in ipoib_init_qp()
117 		ipoib_warn(priv, "failed to modify QP to RTS, ret = %d\n", ret);  in ipoib_init_qp()
125 	if (ib_modify_qp(priv->qp, &qp_attr, IB_QP_STATE))  in ipoib_init_qp()
126 		ipoib_warn(priv, "Failed to modify QP to RESET state\n");  in ipoib_init_qp()
131 int ipoib_transport_dev_init(struct ipoib_dev_priv *priv, struct ib_device *ca)  in ipoib_transport_dev_init()  argument
150 	priv->pd = ib_alloc_pd(priv->ca, 0);  in ipoib_transport_dev_init()
151 	if (IS_ERR(priv->pd)) {  in ipoib_transport_dev_init()
157 	ret = ipoib_cm_dev_init(priv);  in ipoib_transport_dev_init()
160 		if (ipoib_cm_has_srq(priv))  in ipoib_transport_dev_init()
167 	priv->recv_cq = ib_create_cq(priv->ca, ipoib_ib_completion, NULL, priv, &cq_attr);  in ipoib_transport_dev_init()
168 	if (IS_ERR(priv->recv_cq)) {  in ipoib_transport_dev_init()
174 	priv->send_cq = ib_create_cq(priv->ca, ipoib_send_comp_handler, NULL,  in ipoib_transport_dev_init()
175 				     priv, &cq_attr);  in ipoib_transport_dev_init()
176 	if (IS_ERR(priv->send_cq)) {  in ipoib_transport_dev_init()
181 	if (ib_req_notify_cq(priv->recv_cq, IB_CQ_NEXT_COMP))  in ipoib_transport_dev_init()
197 	init_attr.send_cq = priv->send_cq;  in ipoib_transport_dev_init()
198 	init_attr.recv_cq = priv->recv_cq;  in ipoib_transport_dev_init()
200 	if (priv->hca_caps & IB_DEVICE_UD_TSO)  in ipoib_transport_dev_init()
203 	if (priv->hca_caps & IB_DEVICE_BLOCK_MULTICAST_LOOPBACK)  in ipoib_transport_dev_init()
208 	priv->qp = ib_create_qp(priv->pd, &init_attr);  in ipoib_transport_dev_init()
209 	if (IS_ERR(priv->qp)) {  in ipoib_transport_dev_init()
214 	lla = if_getlladdr(priv->dev);  in ipoib_transport_dev_init()
215 	lla[1] = (priv->qp->qp_num >> 16) & 0xff;  in ipoib_transport_dev_init()
216 	lla[2] = (priv->qp->qp_num >>  8) & 0xff;  in ipoib_transport_dev_init()
217 	lla[3] = (priv->qp->qp_num      ) & 0xff;  in ipoib_transport_dev_init()
220 		priv->tx_sge[i].lkey = priv->pd->local_dma_lkey;  in ipoib_transport_dev_init()
222 	priv->tx_wr.wr.opcode		= IB_WR_SEND;  in ipoib_transport_dev_init()
223 	priv->tx_wr.wr.sg_list		= priv->tx_sge;  in ipoib_transport_dev_init()
224 	priv->tx_wr.wr.send_flags	= IB_SEND_SIGNALED;  in ipoib_transport_dev_init()
227 		priv->rx_sge[i].lkey = priv->pd->local_dma_lkey;  in ipoib_transport_dev_init()
228 	priv->rx_wr.next = NULL;  in ipoib_transport_dev_init()
229 	priv->rx_wr.sg_list = priv->rx_sge;  in ipoib_transport_dev_init()
234 	ib_destroy_cq(priv->send_cq);  in ipoib_transport_dev_init()
237 	ib_destroy_cq(priv->recv_cq);  in ipoib_transport_dev_init()
240 	ipoib_cm_dev_cleanup(priv);  in ipoib_transport_dev_init()
242 	ib_dealloc_pd(priv->pd);  in ipoib_transport_dev_init()
246 void ipoib_transport_dev_cleanup(struct ipoib_dev_priv *priv)  in ipoib_transport_dev_cleanup()  argument
249 	if (priv->qp) {  in ipoib_transport_dev_cleanup()
250 		if (ib_destroy_qp(priv->qp))  in ipoib_transport_dev_cleanup()
251 			ipoib_warn(priv, "ib_qp_destroy failed\n");  in ipoib_transport_dev_cleanup()
253 		priv->qp = NULL;  in ipoib_transport_dev_cleanup()
254 		clear_bit(IPOIB_PKEY_ASSIGNED, &priv->flags);  in ipoib_transport_dev_cleanup()
257 	ib_destroy_cq(priv->send_cq);  in ipoib_transport_dev_cleanup()
259 	ib_destroy_cq(priv->recv_cq);  in ipoib_transport_dev_cleanup()
261 	ipoib_cm_dev_cleanup(priv);  in ipoib_transport_dev_cleanup()
263 	ib_dealloc_pd(priv->pd);  in ipoib_transport_dev_cleanup()
269 	struct ipoib_dev_priv *priv =  in ipoib_event()  local
272 	if (record->element.port_num != priv->port)  in ipoib_event()
275 	ipoib_dbg(priv, "Event %d on device %s port %d\n", record->event,  in ipoib_event()
280 		queue_work(ipoib_workqueue, &priv->flush_light);  in ipoib_event()
285 		queue_work(ipoib_workqueue, &priv->flush_normal);  in ipoib_event()
287 		queue_work(ipoib_workqueue, &priv->flush_heavy);  in ipoib_event()