Lines Matching refs:cma_id
420 ret = rdma_create_qp(ib_conn->cma_id, device->pd, &init_attr); in iser_create_ib_conn_res()
424 ib_conn->qp = ib_conn->cma_id->qp; in iser_create_ib_conn_res()
426 ib_conn, ib_conn->cma_id, in iser_create_ib_conn_res()
427 ib_conn->cma_id->qp); in iser_create_ib_conn_res()
444 struct iser_device *iser_device_find_by_ib_device(struct rdma_cm_id *cma_id) in iser_device_find_by_ib_device() argument
452 if (device->ib_device->node_guid == cma_id->device->node_guid) in iser_device_find_by_ib_device()
460 device->ib_device = cma_id->device; in iser_device_find_by_ib_device()
542 iser_conn, ib_conn->cma_id, ib_conn->qp); in iser_free_ib_conn_res()
548 rdma_destroy_qp(ib_conn->cma_id); in iser_free_ib_conn_res()
589 if (ib_conn->cma_id != NULL) { in iser_conn_release()
590 rdma_destroy_id(ib_conn->cma_id); in iser_conn_release()
591 ib_conn->cma_id = NULL; in iser_conn_release()
622 if (ib_conn->cma_id) { in iser_conn_terminate()
623 err = rdma_disconnect(ib_conn->cma_id); in iser_conn_terminate()
638 static void iser_connect_error(struct rdma_cm_id *cma_id) in iser_connect_error() argument
642 iser_conn = (struct iser_conn *)cma_id->context; in iser_connect_error()
690 static void iser_addr_handler(struct rdma_cm_id *cma_id) in iser_addr_handler() argument
697 iser_conn = (struct iser_conn *)cma_id->context; in iser_addr_handler()
703 device = iser_device_find_by_ib_device(cma_id); in iser_addr_handler()
706 iser_connect_error(cma_id); in iser_addr_handler()
727 ret = rdma_resolve_route(cma_id, 1000); in iser_addr_handler()
730 iser_connect_error(cma_id); in iser_addr_handler()
738 static void iser_route_handler(struct rdma_cm_id *cma_id) in iser_route_handler() argument
743 struct iser_conn *iser_conn = (struct iser_conn *)cma_id->context; in iser_route_handler()
768 ret = rdma_connect(cma_id, &conn_param); in iser_route_handler()
776 iser_connect_error(cma_id); in iser_route_handler()
779 static void iser_connected_handler(struct rdma_cm_id *cma_id, in iser_connected_handler() argument
786 iser_conn = (struct iser_conn *)cma_id->context; in iser_connected_handler()
791 (void)ib_query_qp(cma_id->qp, &attr, ~0, &init_attr); in iser_connected_handler()
792 iser_info("remote qpn:%x my qpn:%x\n", attr.dest_qp_num, cma_id->qp->qp_num); in iser_connected_handler()
807 static void iser_disconnected_handler(struct rdma_cm_id *cma_id) in iser_disconnected_handler() argument
809 struct iser_conn *iser_conn = (struct iser_conn *)cma_id->context; in iser_disconnected_handler()
820 static void iser_cleanup_handler(struct rdma_cm_id *cma_id, in iser_cleanup_handler() argument
823 struct iser_conn *iser_conn = (struct iser_conn *)cma_id->context; in iser_cleanup_handler()
830 iser_disconnected_handler(cma_id); in iser_cleanup_handler()
835 static int iser_cma_handler(struct rdma_cm_id *cma_id, struct rdma_cm_event *event) in iser_cma_handler() argument
840 iser_conn = (struct iser_conn *)cma_id->context; in iser_cma_handler()
843 event->status, cma_id->context, cma_id); in iser_cma_handler()
848 iser_addr_handler(cma_id); in iser_cma_handler()
851 iser_route_handler(cma_id); in iser_cma_handler()
854 iser_connected_handler(cma_id, event->param.conn.private_data); in iser_cma_handler()
858 rdma_reject_msg(cma_id, event->status)); in iser_cma_handler()
864 iser_connect_error(cma_id); in iser_cma_handler()
869 iser_cleanup_handler(cma_id, false); in iser_cma_handler()
878 iser_cleanup_handler(cma_id, true); in iser_cma_handler()
880 iser_conn->ib_conn.cma_id = NULL; in iser_cma_handler()
932 ib_conn->cma_id = rdma_create_id(&init_net, iser_cma_handler, in iser_connect()
935 if (IS_ERR(ib_conn->cma_id)) { in iser_connect()
936 err = PTR_ERR(ib_conn->cma_id); in iser_connect()
941 err = rdma_resolve_addr(ib_conn->cma_id, src_addr, dst_addr, 1000); in iser_connect()
963 ib_conn->cma_id = NULL; in iser_connect()