Lines Matching refs:ret
112 int cqe, ret;
116 ret = -ENOMEM;
125 ret = -ENOMEM;
140 ret = rdma_create_qp(node->cma_id, node->pd, &init_qp_attr);
141 if (ret) {
146 ret = create_message(node);
147 if (ret) {
148 printf("cmatose: failed to create messages: %d\n", ret);
152 return ret;
159 int i, ret = 0;
173 for (i = 0; i < message_count && !ret; i++ ) {
174 ret = ibv_post_recv(node->cma_id->qp, &recv_wr, &recv_failure);
175 if (ret) {
176 printf("failed to post receives: %d\n", ret);
180 return ret;
187 int i, ret = 0;
203 for (i = 0; i < message_count && !ret; i++) {
204 ret = ibv_post_send(node->cma_id->qp, &send_wr, &bad_send_wr);
205 if (ret)
206 printf("failed to post sends: %d\n", ret);
208 return ret;
218 int ret;
221 ret = rdma_set_option(node->cma_id, RDMA_OPTION_ID,
223 if (ret)
227 ret = rdma_resolve_route(node->cma_id, 2000);
228 if (ret) {
232 return ret;
238 int ret;
240 ret = init_node(node);
241 if (ret)
244 ret = post_recvs(node);
245 if (ret)
254 ret = rdma_connect(node->cma_id, &conn_param);
255 if (ret) {
262 return ret;
268 int ret;
271 ret = -ENOMEM;
279 ret = init_node(node);
280 if (ret)
283 ret = post_recvs(node);
284 if (ret)
287 ret = rdma_accept(node->cma_id, NULL);
288 if (ret) {
300 return ret;
305 int ret = 0;
309 ret = addr_handler(cma_id->context);
312 ret = route_handler(cma_id->context);
315 ret = connect_handler(cma_id);
330 ret = event->status;
342 return ret;
373 int ret, i;
385 ret = rdma_create_id(test.channel,
388 if (ret)
397 return ret;
412 int done, i, ret;
418 for (done = 0; done < message_count; done += ret) {
419 ret = ibv_poll_cq(test.nodes[i].cq[index], 8, wc);
420 if (ret < 0) {
421 printf("cmatose: failed polling CQ: %d\n", ret);
422 return ret;
432 int ret = 0;
434 while (test.connects_left && !ret) {
435 ret = rdma_get_cm_event(test.channel, &event);
436 if (!ret) {
437 ret = cma_handler(event->id, event);
441 ret = errno;
445 return ret;
451 int ret = 0;
453 while (test.disconnects_left && !ret) {
454 ret = rdma_get_cm_event(test.channel, &event);
455 if (!ret) {
456 ret = cma_handler(event->id, event);
460 ret = errno;
464 return ret;
470 int i, ret;
480 ret = 0;
482 ret = rdma_migrate_id(listen_id, channel);
484 for (i = 0; i < connections && !ret; i++)
485 ret = rdma_migrate_id(test.nodes[i].cma_id, channel);
487 if (!ret) {
493 return ret;
499 int i, ret;
502 ret = rdma_create_id(test.channel, &listen_id, &test, hints.ai_port_space);
503 if (ret) {
505 return ret;
508 ret = get_rdma_addr(src_addr, dst_addr, port, &hints, &test.rai);
509 if (ret) {
510 printf("cmatose: getrdmaaddr error: %s\n", gai_strerror(ret));
514 ret = rdma_bind_addr(listen_id, test.rai->ai_src_addr);
515 if (ret) {
520 ret = rdma_listen(listen_id, 0);
521 if (ret) {
526 ret = connect_events();
527 if (ret)
533 ret = post_sends(&test.nodes[i]);
534 if (ret)
539 ret = poll_cqs(SEND_CQ_INDEX);
540 if (ret)
544 ret = poll_cqs(RECV_CQ_INDEX);
545 if (ret)
552 ret = migrate_channel(listen_id);
553 if (ret)
566 ret = disconnect_events();
572 return ret;
577 int i, ret, ret2;
581 ret = get_rdma_addr(src_addr, dst_addr, port, &hints, &test.rai);
582 if (ret) {
583 printf("cmatose: getaddrinfo error: %s\n", gai_strerror(ret));
584 return ret;
589 ret = rdma_resolve_addr(test.nodes[i].cma_id, test.rai->ai_src_addr,
591 if (ret) {
594 return ret;
598 ret = connect_events();
599 if (ret)
604 ret = poll_cqs(RECV_CQ_INDEX);
605 if (ret)
610 ret = post_sends(&test.nodes[i]);
611 if (ret)
618 ret = 0;
621 ret = migrate_channel(NULL);
622 if (ret)
628 ret = ret2;
630 return ret;
635 int op, ret;
712 ret = run_client();
715 ret = run_server();
724 printf("return status %d\n", ret);
725 return ret;