diff options
| author | Pavel Begunkov <asml.silence@gmail.com> | 2024-09-11 17:34:37 +0100 |
|---|---|---|
| committer | Jens Axboe <axboe@kernel.dk> | 2024-09-11 10:44:10 -0600 |
| commit | 6746ee4c3a189f8b60694f01e7e29bc5ff7972e0 (patch) | |
| tree | 6ab9e275c7681d7a8c2d1c9849fc053376a33527 /io_uring/uring_cmd.c | |
| parent | 6d0f8dcb3a634bbee46fcb028c5984c463f47812 (diff) | |
| download | lwn-6746ee4c3a189f8b60694f01e7e29bc5ff7972e0.tar.gz lwn-6746ee4c3a189f8b60694f01e7e29bc5ff7972e0.zip | |
io_uring/cmd: expose iowq to cmds
When an io_uring request needs blocking context we offload it to the
io_uring's thread pool called io-wq. We can get there off ->uring_cmd
by returning -EAGAIN, but there is no straightforward way of doing that
from an asynchronous callback. Add a helper that would transfer a
command to a blocking context.
Note, we do an extra hop via task_work before io_queue_iowq(), that's a
limitation of io_uring infra we have that can likely be lifted later
if that would ever become a problem.
Signed-off-by: Pavel Begunkov <asml.silence@gmail.com>
Link: https://lore.kernel.org/r/f735f807d7c8ba50c9452c69dfe5d3e9e535037b.1726072086.git.asml.silence@gmail.com
Signed-off-by: Jens Axboe <axboe@kernel.dk>
Diffstat (limited to 'io_uring/uring_cmd.c')
| -rw-r--r-- | io_uring/uring_cmd.c | 7 |
1 files changed, 7 insertions, 0 deletions
diff --git a/io_uring/uring_cmd.c b/io_uring/uring_cmd.c index 8391c7c7c1ec..39c3c816ec78 100644 --- a/io_uring/uring_cmd.c +++ b/io_uring/uring_cmd.c @@ -277,6 +277,13 @@ int io_uring_cmd_import_fixed(u64 ubuf, unsigned long len, int rw, } EXPORT_SYMBOL_GPL(io_uring_cmd_import_fixed); +void io_uring_cmd_issue_blocking(struct io_uring_cmd *ioucmd) +{ + struct io_kiocb *req = cmd_to_io_kiocb(ioucmd); + + io_req_queue_iowq(req); +} + static inline int io_uring_cmd_getsockopt(struct socket *sock, struct io_uring_cmd *cmd, unsigned int issue_flags) |