Lines Matching refs:issue_flags
82 unsigned int issue_flags)
89 return !(issue_flags & IO_URING_F_IOWQ) ||
107 int io_shutdown(struct io_kiocb *req, unsigned int issue_flags)
113 WARN_ON_ONCE(issue_flags & IO_URING_F_NONBLOCK);
131 static void io_netmsg_recycle(struct io_kiocb *req, unsigned int issue_flags)
135 if (!req_has_async_data(req) || issue_flags & IO_URING_F_UNLOCKED)
146 unsigned int issue_flags)
152 if (!(issue_flags & IO_URING_F_UNLOCKED)) {
179 unsigned int issue_flags)
185 async_msg = io_msg_alloc_async(req, issue_flags);
338 unsigned int issue_flags)
345 io = io_msg_alloc_async(req, issue_flags);
401 int io_sendmsg(struct io_kiocb *req, unsigned int issue_flags)
426 return io_setup_async_msg(req, kmsg, issue_flags);
429 if (issue_flags & IO_URING_F_NONBLOCK)
437 if (ret == -EAGAIN && (issue_flags & IO_URING_F_NONBLOCK))
438 return io_setup_async_msg(req, kmsg, issue_flags);
444 return io_setup_async_msg(req, kmsg, issue_flags);
454 io_netmsg_recycle(req, issue_flags);
463 int io_send(struct io_kiocb *req, unsigned int issue_flags)
495 return io_setup_async_addr(req, &__address, issue_flags);
506 if (issue_flags & IO_URING_F_NONBLOCK)
515 if (ret == -EAGAIN && (issue_flags & IO_URING_F_NONBLOCK))
516 return io_setup_async_addr(req, &__address, issue_flags);
523 return io_setup_async_addr(req, &__address, issue_flags);
677 unsigned issue_flags)
681 cflags = io_put_kbuf(req, issue_flags);
698 if (io_fill_cqe_req_aux(req, issue_flags & IO_URING_F_COMPLETE_DEFER,
712 if (issue_flags & IO_URING_F_MULTISHOT)
722 if (issue_flags & IO_URING_F_MULTISHOT)
813 int io_recvmsg(struct io_kiocb *req, unsigned int issue_flags)
820 bool force_nonblock = issue_flags & IO_URING_F_NONBLOCK;
838 return io_setup_async_msg(req, kmsg, issue_flags);
840 if (!io_check_multishot(req, issue_flags))
841 return io_setup_async_msg(req, kmsg, issue_flags);
848 buf = io_buffer_select(req, &len, issue_flags);
855 io_kbuf_recycle(req, issue_flags);
883 ret = io_setup_async_msg(req, kmsg, issue_flags);
884 if (ret == -EAGAIN && (issue_flags & IO_URING_F_MULTISHOT)) {
885 io_kbuf_recycle(req, issue_flags);
893 return io_setup_async_msg(req, kmsg, issue_flags);
907 io_kbuf_recycle(req, issue_flags);
909 if (!io_recv_finish(req, &ret, &kmsg->msg, mshot_finished, issue_flags))
916 io_netmsg_recycle(req, issue_flags);
919 return io_setup_async_msg(req, kmsg, issue_flags);
924 int io_recv(struct io_kiocb *req, unsigned int issue_flags)
931 bool force_nonblock = issue_flags & IO_URING_F_NONBLOCK;
938 if (!io_check_multishot(req, issue_flags))
957 buf = io_buffer_select(req, &len, issue_flags);
980 if (issue_flags & IO_URING_F_MULTISHOT) {
981 io_kbuf_recycle(req, issue_flags);
1007 io_kbuf_recycle(req, issue_flags);
1009 if (!io_recv_finish(req, &ret, &msg, ret <= 0, issue_flags))
1160 int io_send_zc(struct io_kiocb *req, unsigned int issue_flags)
1196 return io_setup_async_addr(req, &__address, issue_flags);
1216 if (issue_flags & IO_URING_F_NONBLOCK)
1227 if (ret == -EAGAIN && (issue_flags & IO_URING_F_NONBLOCK))
1228 return io_setup_async_addr(req, &__address, issue_flags);
1235 return io_setup_async_addr(req, &__address, issue_flags);
1251 if (!(issue_flags & IO_URING_F_UNLOCKED)) {
1259 int io_sendmsg_zc(struct io_kiocb *req, unsigned int issue_flags)
1286 return io_setup_async_msg(req, kmsg, issue_flags);
1289 if (issue_flags & IO_URING_F_NONBLOCK)
1299 if (ret == -EAGAIN && (issue_flags & IO_URING_F_NONBLOCK))
1300 return io_setup_async_msg(req, kmsg, issue_flags);
1305 return io_setup_async_msg(req, kmsg, issue_flags);
1317 io_netmsg_recycle(req, issue_flags);
1327 if (!(issue_flags & IO_URING_F_UNLOCKED)) {
1380 int io_accept(struct io_kiocb *req, unsigned int issue_flags)
1383 bool force_nonblock = issue_flags & IO_URING_F_NONBLOCK;
1389 if (!io_check_multishot(req, issue_flags))
1409 if (issue_flags & IO_URING_F_MULTISHOT)
1420 ret = io_fixed_fd_install(req, issue_flags, file,
1431 if (io_fill_cqe_req_aux(req, issue_flags & IO_URING_F_COMPLETE_DEFER,
1460 int io_socket(struct io_kiocb *req, unsigned int issue_flags)
1477 if (ret == -EAGAIN && (issue_flags & IO_URING_F_NONBLOCK))
1486 ret = io_fixed_fd_install(req, issue_flags, file,
1514 int io_connect(struct io_kiocb *req, unsigned int issue_flags)
1520 bool force_nonblock = issue_flags & IO_URING_F_NONBLOCK;