Lines Matching refs:ret
149 int offset, ret;
158 ret = do_poll(&fds, poll_timeout);
159 if (ret)
160 return ret;
163 ret = rsend(rs, buf + offset, size - offset, flags);
164 if (ret > 0) {
165 offset += ret;
168 return ret;
178 int offset, ret;
187 ret = do_poll(&fds, poll_timeout);
188 if (ret)
189 return ret;
192 ret = riowrite(rs, buf + offset, size - offset, offset, flags);
193 if (ret > 0) {
194 offset += ret;
197 return ret;
207 int offset, ret;
216 ret = do_poll(&fds, poll_timeout);
217 if (ret)
218 return ret;
221 ret = rrecv(rs, buf + offset, size - offset, flags);
222 if (ret > 0) {
223 offset += ret;
226 return ret;
235 int ret;
241 ret = verify_buf(buf, size - 1);
242 if (ret)
243 return ret;
251 int ret;
253 ret = dst_addr ? send_msg(16) : recv_msg(16);
254 if (ret)
255 return ret;
262 int ret, i, t;
271 ret = -1;
274 ret = sync_test();
275 if (ret)
282 ret = send_xfer(transfer_size);
283 if (ret)
289 ret = send_xfer(transfer_size);
290 if (ret)
293 ret = recv_xfer(transfer_size, marker++);
295 ret = recv_xfer(transfer_size, marker++);
296 if (ret)
300 ret = send_xfer(transfer_size);
301 if (ret)
307 ret = send_xfer(transfer_size);
309 if (ret)
314 ret = riounmap(rs, buf, transfer_size);
317 return ret;
356 int val, ret;
360 ret = rdma_getaddrinfo(src_addr, port, &rai_hints, &rai);
363 ret = getaddrinfo(src_addr, port, &ai_hints, &ai);
365 if (ret) {
366 printf("getaddrinfo: %s\n", gai_strerror(ret));
367 return ret;
374 ret = lrs;
379 ret = rsetsockopt(lrs, SOL_SOCKET, SO_REUSEADDR, &val, sizeof val);
380 if (ret) {
385 ret = rai ? rbind(lrs, rai->ai_src_addr, rai->ai_src_len) :
387 if (ret) {
392 ret = rlisten(lrs, 1);
393 if (ret)
397 if (ret)
404 return ret;
410 int ret = 0;
418 ret = do_poll(&fds, poll_timeout);
419 if (ret) {
421 return ret;
433 return ret;
441 int ret, err;
444 ret = use_rgai ? rdma_getaddrinfo(dst_addr, port, &rai_hints, &rai) :
446 if (ret) {
447 printf("getaddrinfo: %s\n", gai_strerror(ret));
448 return ret;
455 ret = rs;
462 ret = rai ? rconnect(rs, rai->ai_dst_addr, rai->ai_dst_len) :
464 if (ret && (errno != EINPROGRESS)) {
469 if (ret && (errno == EINPROGRESS)) {
472 ret = do_poll(&fds, poll_timeout);
473 if (ret) {
479 ret = rgetsockopt(rs, SOL_SOCKET, SO_ERROR, &err, &len);
480 if (ret)
483 ret = -1;
490 if (ret)
497 return ret;
502 int i, ret = 0;
511 ret = server_listen();
512 if (ret)
520 ret = dst_addr ? client_connect() : server_connect();
521 if (ret)
534 ret = dst_addr ? client_connect() : server_connect();
535 if (ret)
544 ret = dst_addr ? client_connect() : server_connect();
545 if (ret)
548 ret = run_test();
555 return ret;
595 int op, ret;
672 ret = run();
673 return ret;