net/rds/rdma_transport.c

40 /* Global IPv4 and IPv6 RDS RDMA listener cm_id */
49 static int rds_rdma_cm_event_handler_cmn(struct rdma_cm_id *cm_id,
54 	struct rds_connection *conn = cm_id->context;
60 	rdsdebug("conn %p id %p handling event %u (%s)\n", conn, cm_id,
63 	if (cm_id->device->node_type == RDMA_NODE_IB_CA)
72 		 * right away. We return 0 so cm_id doesn't get
85 		ret = trans->cm_handle_connect(cm_id, event, isv6);
90 			rdma_set_service_type(cm_id, conn->c_tos);
91 			rdma_set_min_rnr_timer(cm_id, IB_RNR_TIMER_000_32);
93 			ret = rdma_resolve_route(cm_id,
100 		 * cm_id is valid before proceeding
106 			if (ibic && ibic->i_cm_id == cm_id) {
107 				cm_id->route.path_rec[0].sl =
109 				ret = trans->cm_initiate_connect(cm_id, isv6);
124 		err = (int *)rdma_consumer_reject_data(cm_id, event, &len);
137 			 rdma_reject_msg(cm_id, event->status));
177 	rdsdebug("id %p event %u (%s) handling ret %d\n", cm_id, event->event,
183 int rds_rdma_cm_event_handler(struct rdma_cm_id *cm_id,
186 	return rds_rdma_cm_event_handler_cmn(cm_id, event, false);
190 int rds6_rdma_cm_event_handler(struct rdma_cm_id *cm_id,
193 	return rds_rdma_cm_event_handler_cmn(cm_id, event, true);
201 	struct rdma_cm_id *cm_id;
204 	cm_id = rdma_create_id(&init_net, handler, NULL,
206 	if (IS_ERR(cm_id)) {
207 		ret = PTR_ERR(cm_id);
214 	 * XXX I bet this binds the cm_id to a device.  If we want to support
217 	ret = rdma_bind_addr(cm_id, sa);
224 	ret = rdma_listen(cm_id, 128);
231 	rdsdebug("cm %p listening on port %u\n", cm_id, RDS_PORT);
233 	*ret_cm_id = cm_id;
234 	cm_id = NULL;
236 	if (cm_id)
237 		rdma_destroy_id(cm_id);