219 	int ret;  in __req_handler()  local
221 	ret = rdma_create_qp(id, NULL, &init_qp_attr);  in __req_handler()
222 	if (ret) {  in __req_handler()
227 	ret = rdma_accept(id, NULL);  in __req_handler()
228 	if (ret) {  in __req_handler()
353 	int ret, i;  in alloc_nodes()  local
364 			ret = rdma_create_id(channel, &nodes[i].id, &nodes[i],  in alloc_nodes()
366 			if (ret)  in alloc_nodes()
378 	return ret;  in alloc_nodes()
399 	int ret = 0;  in process_events()  local
401 	while (!ret) {  in process_events()
402 		ret = rdma_get_cm_event(channel, &event);  in process_events()
403 		if (!ret) {  in process_events()
407 			ret = errno;  in process_events()
417 	int ret;  in run_server()  local
421 	ret = pthread_mutex_init(&req_work.lock, NULL);  in run_server()
422 	if (ret) {  in run_server()
424 		return ret;  in run_server()
427 	ret = pthread_mutex_init(&disc_work.lock, NULL);  in run_server()
428 	if (ret) {  in run_server()
430 		return ret;  in run_server()
433 	ret = pthread_cond_init(&req_work.cond, NULL);  in run_server()
434 	if (ret) {  in run_server()
436 		return ret;  in run_server()
439 	ret = pthread_cond_init(&disc_work.cond, NULL);  in run_server()
440 	if (ret) {  in run_server()
442 		return ret;  in run_server()
445 	ret = pthread_create(&req_thread, NULL, req_handler_thread, NULL);  in run_server()
446 	if (ret) {  in run_server()
448 		return ret;  in run_server()
451 	ret = pthread_create(&disc_thread, NULL, disc_handler_thread, NULL);  in run_server()
452 	if (ret) {  in run_server()
454 		return ret;  in run_server()
457 	ret = rdma_create_id(channel, &listen_id, NULL, hints.ai_port_space);  in run_server()
458 	if (ret) {  in run_server()
460 		return ret;  in run_server()
463 	ret = get_rdma_addr(src_addr, dst_addr, port, &hints, &rai);  in run_server()
464 	if (ret) {  in run_server()
465 		printf("getrdmaaddr error: %s\n", gai_strerror(ret));  in run_server()
469 	ret = rdma_bind_addr(listen_id, rai->ai_src_addr);  in run_server()
470 	if (ret) {  in run_server()
475 	ret = rdma_listen(listen_id, 0);  in run_server()
476 	if (ret) {  in run_server()
484 	return ret;  in run_server()
490 	int i, ret;  in run_client()  local
492 	ret = get_rdma_addr(src_addr, dst_addr, port, &hints, &rai);  in run_client()
493 	if (ret) {  in run_client()
494 		printf("getaddrinfo error: %s\n", gai_strerror(ret));  in run_client()
495 		return ret;  in run_client()
504 	ret = pthread_create(&event_thread, NULL, process_events, NULL);  in run_client()
505 	if (ret) {  in run_client()
507 		return ret;  in run_client()
515 			ret = rdma_bind_addr(nodes[i].id, rai->ai_src_addr);  in run_client()
516 			if (ret) {  in run_client()
533 		ret = rdma_resolve_addr(nodes[i].id, rai->ai_src_addr,  in run_client()
535 		if (ret) {  in run_client()
552 		ret = rdma_resolve_route(nodes[i].id, timeout);  in run_client()
553 		if (ret) {  in run_client()
569 		ret = rdma_create_qp(nodes[i].id, NULL, &init_qp_attr);  in run_client()
570 		if (ret) {  in run_client()
585 		ret = rdma_connect(nodes[i].id, &conn_param);  in run_client()
586 		if (ret) {  in run_client()
608 	return ret;  in run_client()
613 	int op, ret;  in main()  local
663 		ret = run_client();  in main()
666 		ret = run_server();  in main()
676 	return ret;  in main()