librdmacm/examples/udaddy.c

113 	int ret;
115 	ret = ibv_query_port(node->cma_id->verbs, node->cma_id->port_num,
117 	if (ret)
118 		return ret;
132 	int cqe, ret;
136 		ret = -ENOMEM;
144 		ret = -ENOMEM;
159 	ret = rdma_create_qp(node->cma_id, node->pd, &init_qp_attr);
160 	if (ret) {
165 	ret = create_message(node);
166 	if (ret) {
167 		printf("udaddy: failed to create messages: %d\n", ret);
171 	return ret;
178 	int i, ret = 0;
192 	for (i = 0; i < message_count && !ret; i++ ) {
193 		ret = ibv_post_recv(node->cma_id->qp, &recv_wr, &recv_failure);
194 		if (ret) {
195 			printf("failed to post receives: %d\n", ret);
199 	return ret;
206 	int i, ret = 0;
227 	for (i = 0; i < message_count && !ret; i++) {
228 		ret = ibv_post_send(node->cma_id->qp, &send_wr, &bad_send_wr);
229 		if (ret)
230 			printf("failed to post sends: %d\n", ret);
232 	return ret;
242 	int ret;
245 		ret = rdma_set_option(node->cma_id, RDMA_OPTION_ID,
247 		if (ret)
251 	ret = rdma_resolve_route(node->cma_id, 2000);
252 	if (ret) {
256 	return ret;
262 	int ret;
264 	ret = verify_test_params(node);
265 	if (ret)
268 	ret = init_node(node);
269 	if (ret)
272 	ret = post_recvs(node);
273 	if (ret)
277 	ret = rdma_connect(node->cma_id, &conn_param);
278 	if (ret) {
285 	return ret;
292 	int ret;
295 		ret = -ENOMEM;
303 	ret = verify_test_params(node);
304 	if (ret)
307 	ret = init_node(node);
308 	if (ret)
311 	ret = post_recvs(node);
312 	if (ret)
317 	ret = rdma_accept(node->cma_id, &conn_param);
318 	if (ret) {
332 	return ret;
356 	int ret = 0;
360 		ret = addr_handler(cma_id->context);
363 		ret = route_handler(cma_id->context);
366 		ret = connect_handler(cma_id);
369 		ret = resolved_handler(cma_id->context, event);
379 		ret = event->status;
387 	return ret;
418 	int ret, i;
430 			ret = rdma_create_id(test.channel,
433 			if (ret)
442 	return ret;
470 	int done, i, ret;
476 		for (done = 0; done < message_count; done += ret) {
477 			ret = ibv_poll_cq(test.nodes[i].cq, 8, wc);
478 			if (ret < 0) {
479 				printf("udaddy: failed polling CQ: %d\n", ret);
480 				return ret;
483 			if (ret && !test.nodes[i].ah)
493 	int ret = 0;
495 	while (test.connects_left && !ret) {
496 		ret = rdma_get_cm_event(test.channel, &event);
497 		if (!ret) {
498 			ret = cma_handler(event->id, event);
502 	return ret;
508 	int ret;
510 	ret = getaddrinfo(dst, NULL, NULL, &res);
511 	if (ret) {
513 		return ret;
517 		ret = -1;
524 	return ret;
530 	int i, ret;
533 	ret = rdma_create_id(test.channel, &listen_id, &test, port_space);
534 	if (ret) {
536 		return ret;
540 		ret = get_addr(src_addr, &test.src_in);
541 		if (ret)
547 	ret = rdma_bind_addr(listen_id, test.src_addr);
548 	if (ret) {
550 		return ret;
553 	ret = rdma_listen(listen_id, 0);
554 	if (ret) {
563 		ret = poll_cqs();
564 		if (ret)
569 			ret = post_sends(&test.nodes[i], IBV_SEND_SIGNALED);
570 			if (ret)
574 		ret = poll_cqs();
575 		if (ret)
581 	return ret;
586 	int i, ret;
590 		ret = get_addr(src_addr, &test.src_in);
591 		if (ret)
592 			return ret;
595 	ret = get_addr(dst_addr, &test.dst_in);
596 	if (ret)
597 		return ret;
603 		ret = rdma_resolve_addr(test.nodes[i].cma_id,
606 		if (ret) {
609 			return ret;
613 	ret = connect_events();
614 	if (ret)
620 			ret = post_sends(&test.nodes[i], 0);
621 			if (ret)
625 		ret = poll_cqs();
626 		if (ret)
632 	return ret;
637 	int op, ret;
691 		ret = run_client();
693 		ret = run_server();
699 	printf("return status %d\n", ret);
700 	return ret;