Lines Matching defs:cma_id
49 struct rdma_cm_id *cma_id;
114 node->pd = ibv_alloc_pd(node->cma_id->verbs);
122 node->cq[SEND_CQ_INDEX] = ibv_create_cq(node->cma_id->verbs, cqe, node, NULL, 0);
123 node->cq[RECV_CQ_INDEX] = ibv_create_cq(node->cma_id->verbs, cqe, node, NULL, 0);
140 ret = rdma_create_qp(node->cma_id, node->pd, &init_qp_attr);
174 ret = ibv_post_recv(node->cma_id->qp, &recv_wr, &recv_failure);
204 ret = ibv_post_send(node->cma_id->qp, &send_wr, &bad_send_wr);
221 ret = rdma_set_option(node->cma_id, RDMA_OPTION_ID,
227 ret = rdma_resolve_route(node->cma_id, 2000);
254 ret = rdma_connect(node->cma_id, &conn_param);
265 static int connect_handler(struct rdma_cm_id *cma_id)
276 node->cma_id = cma_id;
277 cma_id->context = node;
287 ret = rdma_accept(node->cma_id, NULL);
295 node->cma_id = NULL;
299 rdma_reject(cma_id, NULL, 0);
303 static int cma_handler(struct rdma_cm_id *cma_id, struct rdma_cm_event *event)
309 ret = addr_handler(cma_id->context);
312 ret = route_handler(cma_id->context);
315 ret = connect_handler(cma_id);
318 ((struct cmatest_node *) cma_id->context)->connected = 1;
333 rdma_disconnect(cma_id);
347 if (!node->cma_id)
350 if (node->cma_id->qp)
351 rdma_destroy_qp(node->cma_id);
368 rdma_destroy_id(node->cma_id);
386 &test.nodes[i].cma_id,
395 rdma_destroy_id(test.nodes[i].cma_id);
485 ret = rdma_migrate_id(test.nodes[i].cma_id, channel);
563 rdma_disconnect(test.nodes[i].cma_id);
589 ret = rdma_resolve_addr(test.nodes[i].cma_id, test.rai->ai_src_addr,