Lines Matching refs:ret
163 int ret = 0;
173 ret = rdma_resolve_route(cma_id, 2000);
174 if (ret) {
213 ret = -1;
224 ret = -1;
233 return ret;
276 int ret;
278 while ((ret = ibv_poll_cq(cb->cq, 1, &wc)) == 1) {
279 ret = 0;
285 ret = -1;
308 ret = cb->server ? server_recv(cb, &wc) :
310 if (ret) {
311 fprintf(stderr, "recv wc error: %d\n", ret);
315 ret = ibv_post_recv(cb->qp, &cb->rq_wr, &bad_wr);
316 if (ret) {
317 fprintf(stderr, "post recv error: %d\n", ret);
325 ret = -1;
329 if (ret) {
330 fprintf(stderr, "poll error %d\n", ret);
338 return ret;
344 int ret;
352 ret = rdma_accept(cb->child_cm_id, &conn_param);
353 if (ret) {
355 return ret;
392 int ret;
406 ret = errno;
413 ret = -ENOMEM;
423 ret = errno;
431 ret = -ENOMEM;
441 ret = errno;
460 return ret;
479 int ret;
491 ret = rdma_create_qp(cb->child_cm_id, cb->pd, &init_attr);
492 if (!ret)
495 ret = rdma_create_qp(cb->cm_id, cb->pd, &init_attr);
496 if (!ret)
500 return ret;
513 int ret;
525 ret = errno;
534 ret = errno;
539 ret = ibv_req_notify_cq(cb->cq, 0);
540 if (ret) {
542 ret = errno;
546 ret = rping_create_qp(cb);
547 if (ret) {
560 return ret;
567 int ret;
570 ret = rdma_get_cm_event(cb->cm_channel, &event);
571 if (ret) {
573 exit(ret);
575 ret = rping_cma_event_handler(event->id, event);
577 if (ret)
578 exit(ret);
587 int ret;
594 ret = ibv_get_cq_event(cb->channel, &ev_cq, &ev_ctx);
595 if (ret) {
603 ret = ibv_req_notify_cq(cb->cq, 0);
604 if (ret) {
608 ret = rping_cq_event_handler(cb);
610 if (ret)
630 int ret;
638 ret = -1;
650 ret = ibv_post_send(cb->qp, &cb->rdma_sq_wr, &bad_wr);
651 if (ret) {
652 fprintf(stderr, "post send error %d\n", ret);
662 ret = -1;
672 ret = ibv_post_send(cb->qp, &cb->sq_wr, &bad_wr);
673 if (ret) {
674 fprintf(stderr, "post send error %d\n", ret);
684 ret = -1;
699 ret = ibv_post_send(cb->qp, &cb->rdma_sq_wr, &bad_wr);
700 if (ret) {
701 fprintf(stderr, "post send error %d\n", ret);
706 ret = sem_wait(&cb->sem);
710 ret = -1;
716 ret = ibv_post_send(cb->qp, &cb->sq_wr, &bad_wr);
717 if (ret) {
718 fprintf(stderr, "post send error %d\n", ret);
724 return ret;
729 int ret;
736 ret = rdma_bind_addr(cb->cm_id, (struct sockaddr *) &cb->sin);
737 if (ret) {
739 return ret;
744 ret = rdma_listen(cb->cm_id, 3);
745 if (ret) {
747 return ret;
772 int ret;
774 ret = rping_setup_qp(cb, cb->child_cm_id);
775 if (ret) {
776 fprintf(stderr, "setup_qp failed: %d\n", ret);
780 ret = rping_setup_buffers(cb);
781 if (ret) {
782 fprintf(stderr, "rping_setup_buffers failed: %d\n", ret);
786 ret = ibv_post_recv(cb->qp, &cb->rq_wr, &bad_wr);
787 if (ret) {
788 fprintf(stderr, "ibv_post_recv failed: %d\n", ret);
794 ret = rping_accept(cb);
795 if (ret) {
796 fprintf(stderr, "connect error %d\n", ret);
822 int ret;
825 ret = rping_bind_server(listening_cb);
826 if (ret)
827 return ret;
848 int ret;
850 ret = rping_bind_server(cb);
851 if (ret)
852 return ret;
861 ret = rping_setup_qp(cb, cb->child_cm_id);
862 if (ret) {
863 fprintf(stderr, "setup_qp failed: %d\n", ret);
864 return ret;
867 ret = rping_setup_buffers(cb);
868 if (ret) {
869 fprintf(stderr, "rping_setup_buffers failed: %d\n", ret);
873 ret = ibv_post_recv(cb->qp, &cb->rq_wr, &bad_wr);
874 if (ret) {
875 fprintf(stderr, "ibv_post_recv failed: %d\n", ret);
881 ret = rping_accept(cb);
882 if (ret) {
883 fprintf(stderr, "connect error %d\n", ret);
896 return ret;
901 int ping, start, cc, i, ret = 0;
923 ret = ibv_post_send(cb->qp, &cb->sq_wr, &bad_wr);
924 if (ret) {
925 fprintf(stderr, "post send error %d\n", ret);
934 ret = -1;
939 ret = ibv_post_send(cb->qp, &cb->sq_wr, &bad_wr);
940 if (ret) {
941 fprintf(stderr, "post send error %d\n", ret);
950 ret = -1;
957 ret = -1;
965 return ret;
971 int ret;
978 ret = rdma_connect(cb->cm_id, &conn_param);
979 if (ret) {
981 return ret;
996 int ret;
1003 ret = rdma_resolve_addr(cb->cm_id, NULL, (struct sockaddr *) &cb->sin, 2000);
1004 if (ret) {
1006 return ret;
1023 int ret;
1025 ret = rping_bind_client(cb);
1026 if (ret)
1027 return ret;
1029 ret = rping_setup_qp(cb, cb->cm_id);
1030 if (ret) {
1031 fprintf(stderr, "setup_qp failed: %d\n", ret);
1032 return ret;
1035 ret = rping_setup_buffers(cb);
1036 if (ret) {
1037 fprintf(stderr, "rping_setup_buffers failed: %d\n", ret);
1041 ret = ibv_post_recv(cb->qp, &cb->rq_wr, &bad_wr);
1042 if (ret) {
1043 fprintf(stderr, "ibv_post_recv failed: %d\n", ret);
1049 ret = rping_connect_client(cb);
1050 if (ret) {
1051 fprintf(stderr, "connect error %d\n", ret);
1055 ret = rping_test_client(cb);
1056 if (ret) {
1057 fprintf(stderr, "rping client failed: %d\n", ret);
1060 ret = 0;
1070 return ret;
1076 int ret;
1078 ret = getaddrinfo(dst, NULL, NULL, &res);
1079 if (ret) {
1081 return ret;
1089 ret = -1;
1092 return ret;
1117 int ret = 0;
1136 ret = get_addr(optarg, (struct sockaddr *) &cb->sin);
1161 ret = EINVAL;
1170 ret = EINVAL;
1187 ret = EINVAL;
1191 if (ret)
1196 ret = EINVAL;
1206 ret = rdma_create_id(cb->cm_channel, &cb->cm_id, cb, RDMA_PS_TCP);
1207 if (ret) {
1217 ret = rping_run_persistent_server(cb);
1219 ret = rping_run_server(cb);
1221 ret = rping_run_client(cb);
1229 return ret;