case rs_init:
case rs_bound:
resolve_addr:
+printf("rs_do_connect - resolve addr\n");
to = 1000 << rs->retries++;
ret = rdma_resolve_addr(rs->cm_id, NULL,
&rs->cm_id->route.addr.dst_addr, to);
rs->state = rs_resolving_addr;
break;
case rs_resolving_addr:
+printf("rs_do_connect - complete resolve addr\n");
ret = ucma_complete(rs->cm_id);
if (ret) {
if (errno == ETIMEDOUT && rs->retries <= RS_CONN_RETRIES)
rs->retries = 0;
resolve_route:
to = 1000 << rs->retries++;
+printf("rs_do_connect - resolve route\n");
ret = rdma_resolve_route(rs->cm_id, to);
if (!ret)
goto do_connect;
rs->state = rs_resolving_route;
break;
case rs_resolving_route:
+printf("rs_do_connect - complete resolve route\n");
ret = ucma_complete(rs->cm_id);
if (ret) {
if (errno == ETIMEDOUT && rs->retries <= RS_CONN_RETRIES)
break;
}
do_connect:
+printf("rs_do_connect - create ep\n");
ret = rs_create_ep(rs);
if (ret)
break;
param.rnr_retry_count = 7;
rs->retries = 0;
+printf("rs_do_connect - connect\n");
ret = rdma_connect(rs->cm_id, ¶m);
if (!ret)
goto connected;
rs->state = rs_connecting;
break;
case rs_connecting:
+printf("rs_do_connect - complete connect\n");
ret = ucma_complete(rs->cm_id);
if (ret)
break;