[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]
[PATCH 06/16] util/async: add aio interfaces for io_uring
From: |
Stefan Hajnoczi |
Subject: |
[PATCH 06/16] util/async: add aio interfaces for io_uring |
Date: |
Mon, 7 Oct 2019 13:09:27 +0100 |
From: Aarushi Mehta <address@hidden>
Signed-off-by: Aarushi Mehta <address@hidden>
Signed-off-by: Stefan Hajnoczi <address@hidden>
---
util/async.c | 36 ++++++++++++++++++++++++++++++++++++
1 file changed, 36 insertions(+)
diff --git a/util/async.c b/util/async.c
index 4e4c7af51e..f8502a9310 100644
--- a/util/async.c
+++ b/util/async.c
@@ -276,6 +276,14 @@ aio_ctx_finalize(GSource *source)
}
#endif
+#ifdef CONFIG_LINUX_IO_URING
+ if (ctx->linux_io_uring) {
+ luring_detach_aio_context(ctx->linux_io_uring, ctx);
+ luring_cleanup(ctx->linux_io_uring);
+ ctx->linux_io_uring = NULL;
+ }
+#endif
+
assert(QSLIST_EMPTY(&ctx->scheduled_coroutines));
qemu_bh_delete(ctx->co_schedule_bh);
@@ -340,6 +348,29 @@ LinuxAioState *aio_get_linux_aio(AioContext *ctx)
}
#endif
+#ifdef CONFIG_LINUX_IO_URING
+LuringState *aio_setup_linux_io_uring(AioContext *ctx, Error **errp)
+{
+ if (ctx->linux_io_uring) {
+ return ctx->linux_io_uring;
+ }
+
+ ctx->linux_io_uring = luring_init(errp);
+ if (!ctx->linux_io_uring) {
+ return NULL;
+ }
+
+ luring_attach_aio_context(ctx->linux_io_uring, ctx);
+ return ctx->linux_io_uring;
+}
+
+LuringState *aio_get_linux_io_uring(AioContext *ctx)
+{
+ assert(ctx->linux_io_uring);
+ return ctx->linux_io_uring;
+}
+#endif
+
void aio_notify(AioContext *ctx)
{
/* Write e.g. bh->scheduled before reading ctx->notify_me. Pairs
@@ -431,6 +462,11 @@ AioContext *aio_context_new(Error **errp)
#ifdef CONFIG_LINUX_AIO
ctx->linux_aio = NULL;
#endif
+
+#ifdef CONFIG_LINUX_IO_URING
+ ctx->linux_io_uring = NULL;
+#endif
+
ctx->thread_pool = NULL;
qemu_rec_mutex_init(&ctx->lock);
timerlistgroup_init(&ctx->tlg, aio_timerlist_notify, ctx);
--
2.21.0
- [PATCH 00/16] io_uring: add Linux io_uring AIO engine, Stefan Hajnoczi, 2019/10/07
- [PATCH 01/16] configure: permit use of io_uring, Stefan Hajnoczi, 2019/10/07
- [PATCH 02/16] qapi/block-core: add option for io_uring, Stefan Hajnoczi, 2019/10/07
- [PATCH 03/16] block/block: add BDRV flag for io_uring, Stefan Hajnoczi, 2019/10/07
- [PATCH 05/16] stubs: add stubs for io_uring interface, Stefan Hajnoczi, 2019/10/07
- [PATCH 04/16] block/io_uring: implements interfaces for io_uring, Stefan Hajnoczi, 2019/10/07
- [PATCH 06/16] util/async: add aio interfaces for io_uring,
Stefan Hajnoczi <=
- [PATCH 07/16] blockdev: adds bdrv_parse_aio to use io_uring, Stefan Hajnoczi, 2019/10/07
- [PATCH 08/16] block/file-posix.c: extend to use io_uring, Stefan Hajnoczi, 2019/10/07
- [PATCH 09/16] block: add trace events for io_uring, Stefan Hajnoczi, 2019/10/07
- [PATCH 10/16] block/io_uring: adds userspace completion polling, Stefan Hajnoczi, 2019/10/07
- [PATCH 11/16] qemu-io: adds option to use aio engine, Stefan Hajnoczi, 2019/10/07
- [PATCH 12/16] qemu-img: adds option to use aio engine for benchmarking, Stefan Hajnoczi, 2019/10/07
- [PATCH 13/16] qemu-nbd: adds option for aio engines, Stefan Hajnoczi, 2019/10/07
- [PATCH 14/16] tests/qemu-iotests: enable testing with aio options, Stefan Hajnoczi, 2019/10/07
- [PATCH 15/16] tests/qemu-iotests: use AIOMODE with various tests, Stefan Hajnoczi, 2019/10/07
- [PATCH 16/16] block/io_uring: adds fd registration, Stefan Hajnoczi, 2019/10/07