40 	struct ipoib_dev_priv *priv = netdev_priv(dev);  in ipoib_mcast_attach()  local
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()
79 	struct ipoib_dev_priv *priv = netdev_priv(dev);  in ipoib_init_qp()  local
84 	if (!test_bit(IPOIB_PKEY_ASSIGNED, &priv->flags))  in ipoib_init_qp()
89 	qp_attr.port_num = priv->port;  in ipoib_init_qp()
90 	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()
133 	struct ipoib_dev_priv *priv = netdev_priv(dev);  in ipoib_transport_dev_init()  local
149 	priv->pd = ib_alloc_pd(priv->ca);  in ipoib_transport_dev_init()
150 	if (IS_ERR(priv->pd)) {  in ipoib_transport_dev_init()
159 	priv->wq = create_singlethread_workqueue("ipoib_wq");  in ipoib_transport_dev_init()
160 	if (!priv->wq) {  in ipoib_transport_dev_init()
178 	priv->recv_cq = ib_create_cq(priv->ca, ipoib_ib_completion, NULL,  in ipoib_transport_dev_init()
180 	if (IS_ERR(priv->recv_cq)) {  in ipoib_transport_dev_init()
186 	priv->send_cq = ib_create_cq(priv->ca, ipoib_send_comp_handler, NULL,  in ipoib_transport_dev_init()
188 	if (IS_ERR(priv->send_cq)) {  in ipoib_transport_dev_init()
193 	if (ib_req_notify_cq(priv->recv_cq, IB_CQ_NEXT_COMP))  in ipoib_transport_dev_init()
196 	init_attr.send_cq = priv->send_cq;  in ipoib_transport_dev_init()
197 	init_attr.recv_cq = priv->recv_cq;  in ipoib_transport_dev_init()
199 	if (priv->hca_caps & IB_DEVICE_UD_TSO)  in ipoib_transport_dev_init()
202 	if (priv->hca_caps & IB_DEVICE_BLOCK_MULTICAST_LOOPBACK)  in ipoib_transport_dev_init()
205 	if (priv->hca_caps & IB_DEVICE_MANAGED_FLOW_STEERING)  in ipoib_transport_dev_init()
211 	priv->qp = ib_create_qp(priv->pd, &init_attr);  in ipoib_transport_dev_init()
212 	if (IS_ERR(priv->qp)) {  in ipoib_transport_dev_init()
217 	priv->dev->dev_addr[1] = (priv->qp->qp_num >> 16) & 0xff;  in ipoib_transport_dev_init()
218 	priv->dev->dev_addr[2] = (priv->qp->qp_num >>  8) & 0xff;  in ipoib_transport_dev_init()
219 	priv->dev->dev_addr[3] = (priv->qp->qp_num      ) & 0xff;  in ipoib_transport_dev_init()
222 		priv->tx_sge[i].lkey = priv->pd->local_dma_lkey;  in ipoib_transport_dev_init()
224 	priv->tx_wr.wr.opcode		= IB_WR_SEND;  in ipoib_transport_dev_init()
225 	priv->tx_wr.wr.sg_list		= priv->tx_sge;  in ipoib_transport_dev_init()
226 	priv->tx_wr.wr.send_flags	= IB_SEND_SIGNALED;  in ipoib_transport_dev_init()
228 	priv->rx_sge[0].lkey = priv->pd->local_dma_lkey;  in ipoib_transport_dev_init()
230 	priv->rx_sge[0].length = IPOIB_UD_BUF_SIZE(priv->max_ib_mtu);  in ipoib_transport_dev_init()
231 	priv->rx_wr.num_sge = 1;  in ipoib_transport_dev_init()
233 	priv->rx_wr.next = NULL;  in ipoib_transport_dev_init()
234 	priv->rx_wr.sg_list = priv->rx_sge;  in ipoib_transport_dev_init()
239 	ib_destroy_cq(priv->send_cq);  in ipoib_transport_dev_init()
242 	ib_destroy_cq(priv->recv_cq);  in ipoib_transport_dev_init()
248 	destroy_workqueue(priv->wq);  in ipoib_transport_dev_init()
249 	priv->wq = NULL;  in ipoib_transport_dev_init()
252 	ib_dealloc_pd(priv->pd);  in ipoib_transport_dev_init()
259 	struct ipoib_dev_priv *priv = netdev_priv(dev);  in ipoib_transport_dev_cleanup()  local
261 	if (priv->qp) {  in ipoib_transport_dev_cleanup()
262 		if (ib_destroy_qp(priv->qp))  in ipoib_transport_dev_cleanup()
263 			ipoib_warn(priv, "ib_qp_destroy failed\n");  in ipoib_transport_dev_cleanup()
265 		priv->qp = NULL;  in ipoib_transport_dev_cleanup()
266 		clear_bit(IPOIB_PKEY_ASSIGNED, &priv->flags);  in ipoib_transport_dev_cleanup()
269 	if (ib_destroy_cq(priv->send_cq))  in ipoib_transport_dev_cleanup()
270 		ipoib_warn(priv, "ib_cq_destroy (send) failed\n");  in ipoib_transport_dev_cleanup()
272 	if (ib_destroy_cq(priv->recv_cq))  in ipoib_transport_dev_cleanup()
273 		ipoib_warn(priv, "ib_cq_destroy (recv) failed\n");  in ipoib_transport_dev_cleanup()
277 	if (priv->wq) {  in ipoib_transport_dev_cleanup()
278 		flush_workqueue(priv->wq);  in ipoib_transport_dev_cleanup()
279 		destroy_workqueue(priv->wq);  in ipoib_transport_dev_cleanup()
280 		priv->wq = NULL;  in ipoib_transport_dev_cleanup()
283 	ib_dealloc_pd(priv->pd);  in ipoib_transport_dev_cleanup()
289 	struct ipoib_dev_priv *priv =  in ipoib_event()  local
292 	if (record->element.port_num != priv->port)  in ipoib_event()
295 	ipoib_dbg(priv, "Event %d on device %s port %d\n", record->event,  in ipoib_event()
300 		queue_work(ipoib_workqueue, &priv->flush_light);  in ipoib_event()
304 		queue_work(ipoib_workqueue, &priv->flush_normal);  in ipoib_event()
306 		queue_work(ipoib_workqueue, &priv->flush_heavy);  in ipoib_event()