Lines Matching refs:ret
89 int ret; in io_shutdown() local
98 ret = __sys_shutdown_sock(sock, shutdown->how); in io_shutdown()
99 io_req_set_res(req, ret, 0); in io_shutdown()
190 int ret; in io_sendmsg_copy_hdr() local
194 ret = sendmsg_copy_msghdr(&iomsg->msg, sr->umsg, sr->msg_flags, in io_sendmsg_copy_hdr()
198 return ret; in io_sendmsg_copy_hdr()
205 int ret; in io_send_prep_async() local
212 ret = move_addr_to_kernel(zc->addr, zc->addr_len, &io->addr); in io_send_prep_async()
213 return ret; in io_send_prep_async()
234 int ret; in io_sendmsg_prep_async() local
238 ret = io_sendmsg_copy_hdr(req, req->async_data); in io_sendmsg_prep_async()
239 if (!ret) in io_sendmsg_prep_async()
241 return ret; in io_sendmsg_prep_async()
288 int ret; in io_sendmsg() local
298 ret = io_sendmsg_copy_hdr(req, &iomsg); in io_sendmsg()
299 if (ret) in io_sendmsg()
300 return ret; in io_sendmsg()
314 ret = __sys_sendmsg_sock(sock, &kmsg->msg, flags); in io_sendmsg()
316 if (ret < min_ret) { in io_sendmsg()
317 if (ret == -EAGAIN && (issue_flags & IO_URING_F_NONBLOCK)) in io_sendmsg()
319 if (ret > 0 && io_net_retry(sock, flags)) { in io_sendmsg()
322 sr->done_io += ret; in io_sendmsg()
326 if (ret == -ERESTARTSYS) in io_sendmsg()
327 ret = -EINTR; in io_sendmsg()
335 if (ret >= 0) in io_sendmsg()
336 ret += sr->done_io; in io_sendmsg()
338 ret = sr->done_io; in io_sendmsg()
339 io_req_set_res(req, ret, 0); in io_sendmsg()
352 int ret; in io_send() local
366 ret = move_addr_to_kernel(sr->addr, sr->addr_len, &__address); in io_send()
367 if (unlikely(ret < 0)) in io_send()
368 return ret; in io_send()
382 ret = import_single_range(ITER_SOURCE, sr->buf, sr->len, &iov, &msg.msg_iter); in io_send()
383 if (unlikely(ret)) in io_send()
384 return ret; in io_send()
394 ret = sock_sendmsg(sock, &msg); in io_send()
395 if (ret < min_ret) { in io_send()
396 if (ret == -EAGAIN && (issue_flags & IO_URING_F_NONBLOCK)) in io_send()
399 if (ret > 0 && io_net_retry(sock, flags)) { in io_send()
400 sr->len -= ret; in io_send()
401 sr->buf += ret; in io_send()
402 sr->done_io += ret; in io_send()
406 if (ret == -ERESTARTSYS) in io_send()
407 ret = -EINTR; in io_send()
410 if (ret >= 0) in io_send()
411 ret += sr->done_io; in io_send()
413 ret = sr->done_io; in io_send()
414 io_req_set_res(req, ret, 0); in io_send()
438 int ret; in __io_recvmsg_copy_hdr() local
443 ret = __copy_msghdr(&iomsg->msg, &msg, &iomsg->uaddr); in __io_recvmsg_copy_hdr()
444 if (ret) in __io_recvmsg_copy_hdr()
445 return ret; in __io_recvmsg_copy_hdr()
469 ret = __import_iovec(ITER_DEST, msg.msg_iov, msg.msg_iovlen, UIO_FASTIOV, in __io_recvmsg_copy_hdr()
472 if (ret > 0) in __io_recvmsg_copy_hdr()
473 ret = 0; in __io_recvmsg_copy_hdr()
476 return ret; in __io_recvmsg_copy_hdr()
486 int ret; in __io_compat_recvmsg_copy_hdr() local
491 ret = __get_compat_msghdr(&iomsg->msg, &msg, &iomsg->uaddr); in __io_compat_recvmsg_copy_hdr()
492 if (ret) in __io_compat_recvmsg_copy_hdr()
493 return ret; in __io_compat_recvmsg_copy_hdr()
522 ret = __import_iovec(ITER_DEST, (struct iovec __user *)uiov, msg.msg_iovlen, in __io_compat_recvmsg_copy_hdr()
525 if (ret < 0) in __io_compat_recvmsg_copy_hdr()
526 return ret; in __io_compat_recvmsg_copy_hdr()
549 int ret; in io_recvmsg_prep_async() local
553 ret = io_recvmsg_copy_hdr(req, req->async_data); in io_recvmsg_prep_async()
554 if (!ret) in io_recvmsg_prep_async()
556 return ret; in io_recvmsg_prep_async()
620 static inline bool io_recv_finish(struct io_kiocb *req, int *ret, in io_recv_finish() argument
625 io_req_set_res(req, *ret, cflags); in io_recv_finish()
626 *ret = IOU_OK; in io_recv_finish()
631 if (io_post_aux_cqe(req->ctx, req->cqe.user_data, *ret, in io_recv_finish()
643 io_req_set_res(req, *ret, cflags); in io_recv_finish()
646 *ret = IOU_STOP_MULTISHOT; in io_recv_finish()
648 *ret = IOU_OK; in io_recv_finish()
743 int ret, min_ret = 0; in io_recvmsg() local
754 ret = io_recvmsg_copy_hdr(req, &iomsg); in io_recvmsg()
755 if (ret) in io_recvmsg()
756 return ret; in io_recvmsg()
774 ret = io_recvmsg_prep_multishot(kmsg, sr, &buf, &len); in io_recvmsg()
775 if (ret) { in io_recvmsg()
777 return ret; in io_recvmsg()
793 ret = io_recvmsg_multishot(sock, sr, kmsg, flags, in io_recvmsg()
800 ret = __sys_recvmsg_sock(sock, &kmsg->msg, sr->umsg, in io_recvmsg()
804 if (ret < min_ret) { in io_recvmsg()
805 if (ret == -EAGAIN && force_nonblock) { in io_recvmsg()
806 ret = io_setup_async_msg(req, kmsg, issue_flags); in io_recvmsg()
807 if (ret == -EAGAIN && (issue_flags & IO_URING_F_MULTISHOT)) { in io_recvmsg()
811 return ret; in io_recvmsg()
813 if (ret > 0 && io_net_retry(sock, flags)) { in io_recvmsg()
814 sr->done_io += ret; in io_recvmsg()
818 if (ret == -ERESTARTSYS) in io_recvmsg()
819 ret = -EINTR; in io_recvmsg()
825 if (ret > 0) in io_recvmsg()
826 ret += sr->done_io; in io_recvmsg()
828 ret = sr->done_io; in io_recvmsg()
836 if (!io_recv_finish(req, &ret, cflags, mshot_finished, issue_flags)) in io_recvmsg()
847 return ret; in io_recvmsg()
858 int ret, min_ret = 0; in io_recv() local
881 ret = import_single_range(ITER_DEST, sr->buf, len, &iov, &msg.msg_iter); in io_recv()
882 if (unlikely(ret)) in io_recv()
900 ret = sock_recvmsg(sock, &msg, flags); in io_recv()
901 if (ret < min_ret) { in io_recv()
902 if (ret == -EAGAIN && force_nonblock) { in io_recv()
910 if (ret > 0 && io_net_retry(sock, flags)) { in io_recv()
911 sr->len -= ret; in io_recv()
912 sr->buf += ret; in io_recv()
913 sr->done_io += ret; in io_recv()
917 if (ret == -ERESTARTSYS) in io_recv()
918 ret = -EINTR; in io_recv()
925 if (ret > 0) in io_recv()
926 ret += sr->done_io; in io_recv()
928 ret = sr->done_io; in io_recv()
936 if (!io_recv_finish(req, &ret, cflags, ret <= 0, issue_flags)) in io_recv()
939 return ret; in io_recv()
1035 int ret = 0; in io_sg_from_iter() local
1059 ret = -EMSGSIZE; in io_sg_from_iter()
1078 return ret; in io_sg_from_iter()
1089 int ret, min_ret = 0; in io_send_zc() local
1108 ret = move_addr_to_kernel(zc->addr, zc->addr_len, &__address); in io_send_zc()
1109 if (unlikely(ret < 0)) in io_send_zc()
1110 return ret; in io_send_zc()
1121 ret = io_import_fixed(ITER_SOURCE, &msg.msg_iter, req->imu, in io_send_zc()
1123 if (unlikely(ret)) in io_send_zc()
1124 return ret; in io_send_zc()
1127 ret = import_single_range(ITER_SOURCE, zc->buf, zc->len, &iov, in io_send_zc()
1129 if (unlikely(ret)) in io_send_zc()
1130 return ret; in io_send_zc()
1131 ret = io_notif_account_mem(zc->notif, zc->len); in io_send_zc()
1132 if (unlikely(ret)) in io_send_zc()
1133 return ret; in io_send_zc()
1146 ret = sock_sendmsg(sock, &msg); in io_send_zc()
1148 if (unlikely(ret < min_ret)) { in io_send_zc()
1149 if (ret == -EAGAIN && (issue_flags & IO_URING_F_NONBLOCK)) in io_send_zc()
1152 if (ret > 0 && io_net_retry(sock, msg.msg_flags)) { in io_send_zc()
1153 zc->len -= ret; in io_send_zc()
1154 zc->buf += ret; in io_send_zc()
1155 zc->done_io += ret; in io_send_zc()
1159 if (ret == -ERESTARTSYS) in io_send_zc()
1160 ret = -EINTR; in io_send_zc()
1164 if (ret >= 0) in io_send_zc()
1165 ret += zc->done_io; in io_send_zc()
1167 ret = zc->done_io; in io_send_zc()
1177 io_req_set_res(req, ret, IORING_CQE_F_MORE); in io_send_zc()
1187 int ret, min_ret = 0; in io_sendmsg_zc() local
1198 ret = io_sendmsg_copy_hdr(req, &iomsg); in io_sendmsg_zc()
1199 if (ret) in io_sendmsg_zc()
1200 return ret; in io_sendmsg_zc()
1216 ret = __sys_sendmsg_sock(sock, &kmsg->msg, flags); in io_sendmsg_zc()
1218 if (unlikely(ret < min_ret)) { in io_sendmsg_zc()
1219 if (ret == -EAGAIN && (issue_flags & IO_URING_F_NONBLOCK)) in io_sendmsg_zc()
1222 if (ret > 0 && io_net_retry(sock, flags)) { in io_sendmsg_zc()
1223 sr->done_io += ret; in io_sendmsg_zc()
1227 if (ret == -ERESTARTSYS) in io_sendmsg_zc()
1228 ret = -EINTR; in io_sendmsg_zc()
1238 if (ret >= 0) in io_sendmsg_zc()
1239 ret += sr->done_io; in io_sendmsg_zc()
1241 ret = sr->done_io; in io_sendmsg_zc()
1251 io_req_set_res(req, ret, IORING_CQE_F_MORE); in io_sendmsg_zc()
1308 int ret, fd; in io_accept() local
1321 ret = PTR_ERR(file); in io_accept()
1322 if (ret == -EAGAIN && force_nonblock) { in io_accept()
1330 return ret; in io_accept()
1332 if (ret == -ERESTARTSYS) in io_accept()
1333 ret = -EINTR; in io_accept()
1337 ret = fd; in io_accept()
1339 ret = io_fixed_fd_install(req, issue_flags, file, in io_accept()
1344 io_req_set_res(req, ret, 0); in io_accept()
1348 if (ret < 0) in io_accept()
1349 return ret; in io_accept()
1350 if (io_post_aux_cqe(ctx, req->cqe.user_data, ret, IORING_CQE_F_MORE, false)) in io_accept()
1353 io_req_set_res(req, ret, 0); in io_accept()
1383 int ret, fd; in io_socket() local
1394 ret = PTR_ERR(file); in io_socket()
1395 if (ret == -EAGAIN && (issue_flags & IO_URING_F_NONBLOCK)) in io_socket()
1397 if (ret == -ERESTARTSYS) in io_socket()
1398 ret = -EINTR; in io_socket()
1402 ret = fd; in io_socket()
1404 ret = io_fixed_fd_install(req, issue_flags, file, in io_socket()
1407 io_req_set_res(req, ret, 0); in io_socket()
1437 int ret; in io_connect() local
1443 ret = move_addr_to_kernel(connect->addr, in io_connect()
1446 if (ret) in io_connect()
1453 ret = __sys_connect_file(req->file, &io->address, in io_connect()
1455 if ((ret == -EAGAIN || ret == -EINPROGRESS || ret == -ECONNABORTED) in io_connect()
1457 if (ret == -EINPROGRESS) { in io_connect()
1459 } else if (ret == -ECONNABORTED) { in io_connect()
1467 ret = -ENOMEM; in io_connect()
1480 if (ret == -EBADFD || ret == -EISCONN) in io_connect()
1481 ret = sock_error(sock_from_file(req->file)->sk); in io_connect()
1483 if (ret == -ERESTARTSYS) in io_connect()
1484 ret = -EINTR; in io_connect()
1486 if (ret < 0) in io_connect()
1488 io_req_set_res(req, ret, 0); in io_connect()