librdmacm/examples/mckey.c

51 	struct rdma_cm_id	*cma_id;
116 	ret = ibv_query_port(node->cma_id->verbs, node->cma_id->port_num,
135 	node->pd = ibv_alloc_pd(node->cma_id->verbs);
143 	node->cq = ibv_create_cq(node->cma_id->verbs, cqe, node, NULL, 0);
160 	ret = rdma_create_qp(node->cma_id, node->pd, &init_qp_attr);
194 		ret = ibv_post_recv(node->cma_id->qp, &recv_wr, &recv_failure);
218 	send_wr.imm_data = htobe32(node->cma_id->qp->qp_num);
229 		ret = ibv_post_send(node->cma_id->qp, &send_wr, &bad_send_wr);
259 	ret = rdma_join_multicast(node->cma_id, test.dst_addr, node);
295 static int cma_handler(struct rdma_cm_id *cma_id, struct rdma_cm_event *event)
301 		ret = addr_handler(cma_id->context);
304 		ret = join_handler(cma_id->context, &event->param.ud);
352 	if (!node->cma_id)
358 	if (node->cma_id->qp)
359 		rdma_destroy_qp(node->cma_id);
373 	rdma_destroy_id(node->cma_id);
389 		ret = rdma_create_id(test.channel, &test.nodes[i].cma_id,
397 		rdma_destroy_id(test.nodes[i].cma_id);
494 			ret = rdma_bind_addr(test.nodes[i].cma_id,
506 			ret = rdma_resolve_addr(test.nodes[i].cma_id,
546 		err = rdma_leave_multicast(test.nodes[i].cma_id,