[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]
[Qemu-devel] [RFC PATCH 5/9] util/asyn: add aio interfaces for io_uring
From: |
Aarushi Mehta |
Subject: |
[Qemu-devel] [RFC PATCH 5/9] util/asyn: add aio interfaces for io_uring |
Date: |
Wed, 22 May 2019 05:22:11 +0530 |
Signed-off-by: Aarushi Mehta <address@hidden>
---
util/async.c | 32 ++++++++++++++++++++++++++++++++
1 file changed, 32 insertions(+)
diff --git a/util/async.c b/util/async.c
index c10642a385..dd45aff8f5 100644
--- a/util/async.c
+++ b/util/async.c
@@ -277,6 +277,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);
@@ -341,6 +349,25 @@ 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) {
+ ctx->linux_io_uring = luring_init(errp);
+ if (ctx->linux_io_uring) {
+ 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
@@ -432,6 +459,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.17.1
- [Qemu-devel] [RFC PATCH 0/9] Add support for io_uring, Aarushi Mehta, 2019/05/21
- [Qemu-devel] [RFC PATCH 9/9] configure: permits use of io_uring with probe, Aarushi Mehta, 2019/05/21
- [Qemu-devel] [RFC PATCH 8/9] block/file-posix: extends to use with io_uring, Aarushi Mehta, 2019/05/21
- [Qemu-devel] [RFC PATCH 7/9] blockdev: accept io_uring as option, Aarushi Mehta, 2019/05/21
- [Qemu-devel] [RFC PATCH 6/9] block/io_uring: implements interfaces for io_uring, Aarushi Mehta, 2019/05/21
- [Qemu-devel] [RFC PATCH 5/9] util/asyn: add aio interfaces for io_uring,
Aarushi Mehta <=
- [Qemu-devel] [RFC PATCH 4/9] stubs: add aio interface stubs for io_uring, Aarushi Mehta, 2019/05/21
- [Qemu-devel] [RFC PATCH 3/9] include/block: declare interfaces for io_uring, Aarushi Mehta, 2019/05/21
- [Qemu-devel] [RFC PATCH 1/9] qapi/block-core: add option for io_uring, Aarushi Mehta, 2019/05/21