struct rs_conn_data *creq, cresp;
int ret;
+ printf("raccept %d\n", socket);
rs = idm_at(&idm, socket);
new_rs = rs_alloc(rs);
if (!new_rs)
return ERR(ENOMEM);
ret = rdma_get_request(rs->cm_id, &new_rs->cm_id);
+ printf("raccept get request %d\n", ret);
if (ret)
goto err;
ret = rs_insert(new_rs);
+ printf("raccept insert %d\n", ret);
if (ret < 0)
goto err;
rs_set_nonblocking(new_rs, O_NONBLOCK);
ret = rs_create_ep(new_rs);
+ printf("raccept create ep %d\n", ret);
if (ret)
goto err;
param = new_rs->cm_id->event->param.conn;
rs_set_conn_data(new_rs, ¶m, &cresp);
ret = rdma_accept(new_rs->cm_id, ¶m);
+ printf("raccept rdma accept %d\n", ret);
if (!ret)
new_rs->state = rs_connect_rdwr;
else if (errno == EAGAIN || errno == EWOULDBLOCK)