ulp/sdp/sdp_cma.c

69 sdp_init_qp(struct socket *sk, struct rdma_cm_id *id)
78 	struct ib_device *device = id->device;
114 	rc = rdma_create_qp(id, ssk->sdp_dev->pd, &qp_init_attr);
119 	ssk->qp = id->qp;
136 sdp_connect_handler(struct socket *sk, struct rdma_cm_id *id,
146 	sdp_dbg(sk, "%s %p -> %p\n", __func__, sdp_sk(sk)->id, id);
159 	rc = sdp_init_qp(child, id);
163 	id->context = ssk;
164 	ssk->id = id;
167 	dst_addr = (struct sockaddr_in *)&id->route.addr.dst_addr;
168 	src_addr = (struct sockaddr_in *)&id->route.addr.src_addr;
184 sdp_response_handler(struct socket *sk, struct rdma_cm_id *id,
211 	dst_addr = (struct sockaddr_in *)&id->route.addr.dst_addr;
262 sdp_cma_handler(struct rdma_cm_id *id, struct rdma_cm_event *event)
272 	ssk = id->context;
276 	if (!ssk || !sk || !ssk->id) {
278 		    "cm_id is being torn down, event %d, ssk %p, sk %p, id %p\n",
279 		       	event->event, ssk, sk, id);
284 	sdp_dbg(sk, "%s event %d id %p\n", __func__, event->event, id);
290 			rdma_node_get_transport(id->device->node_type) ==
292 			rdma_port_get_link_layer(id->device, id->port_num) !=
296 				rdma_port_get_link_layer(id->device, id->port_num));
301 		rc = rdma_resolve_route(id, SDP_ROUTE_TIMEOUT);
308 		sdp_dbg(sk, "RDMA_CM_EVENT_ROUTE_RESOLVED : %p\n", id);
309 		rc = sdp_init_qp(sk, id);
325 			((struct sockaddr_in *)&id->route.addr.src_addr)->sin_addr.s_addr;
333 		rc = rdma_connect(id, &conn_param);
336 		sdp_dbg(sk, "RDMA_CM_EVENT_ROUTE_ERROR : %p\n", id);
341 		rc = sdp_connect_handler(sk, id, event);
344 			rdma_reject(id, NULL, 0);
347 		ssk = id->context;
364 		rc = rdma_accept(id, &conn_param);
366 			ssk->id = NULL;
367 			id->qp = NULL;
368 			id->context = NULL;
373 		rc = sdp_response_handler(sk, id, event);
376 			rdma_reject(id, NULL, 0);
378 			rc = rdma_accept(id, NULL);
395 			((struct sockaddr_in *)&id->route.addr.src_addr)->sin_addr.s_addr;
410 		rdma_disconnect(id);
445 		if (ssk->id == id) {
446 			ssk->id = NULL;
447 			id->qp = NULL;
448 			id->context = NULL;