Lines Matching refs:cma_id
49 struct rdma_cm_id *cma_id;
111 ret = ibv_query_port(node->cma_id->verbs, node->cma_id->port_num,
130 node->pd = ibv_alloc_pd(node->cma_id->verbs);
138 node->cq = ibv_create_cq(node->cma_id->verbs, cqe, node, NULL, 0);
155 ret = rdma_create_qp(node->cma_id, node->pd, &init_qp_attr);
189 ret = ibv_post_recv(node->cma_id->qp, &recv_wr, &recv_failure);
213 send_wr.imm_data = htobe32(node->cma_id->qp->qp_num);
224 ret = ibv_post_send(node->cma_id->qp, &send_wr, &bad_send_wr);
241 ret = rdma_set_option(node->cma_id, RDMA_OPTION_ID,
247 ret = rdma_resolve_route(node->cma_id, 2000);
275 ret = rdma_connect(node->cma_id, &conn_param);
286 static int connect_handler(struct rdma_cm_id *cma_id)
298 node->cma_id = cma_id;
299 cma_id->context = node;
314 conn_param.qp_num = node->cma_id->qp->qp_num;
315 ret = rdma_accept(node->cma_id, &conn_param);
325 node->cma_id = NULL;
329 rdma_reject(cma_id, NULL, 0);
352 static int cma_handler(struct rdma_cm_id *cma_id, struct rdma_cm_event *event)
358 ret = addr_handler(cma_id->context);
361 ret = route_handler(cma_id->context);
364 ret = connect_handler(cma_id);
367 ret = resolved_handler(cma_id->context, event);
390 if (!node->cma_id)
396 if (node->cma_id->qp)
397 rdma_destroy_qp(node->cma_id);
411 rdma_destroy_id(node->cma_id);
429 &test.nodes[i].cma_id,
438 rdma_destroy_id(test.nodes[i].cma_id);
458 node->cma_id->port_num);
461 ibv_query_qp(node->cma_id->qp, &attr, IBV_QP_QKEY, &init_attr);
572 ret = rdma_resolve_addr(test.nodes[i].cma_id, test.rai->ai_src_addr,