[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]
[Qemu-devel] [PATCH v2 08/13] main-loop: use thread-local AioContext
From: |
Stefan Hajnoczi |
Subject: |
[Qemu-devel] [PATCH v2 08/13] main-loop: use thread-local AioContext |
Date: |
Mon, 15 Jul 2013 22:42:57 +0800 |
qemu_bh_new() and several other functions use qemu_aio_context, the
global QEMU main loop AioContext. Now that we have introduced threads
with their own AioContext and a thread-local AioContext pointer, convert
qemu_bh_new() and friends to use the thread-local AioContext pointer.
qemu_bh_new() now creates a QEMUBH for the current thread's AioContext.
This is the right thing to do - it allows existing code to work outside
the main loop thread.
One exception: qemu_notify_event() still uses the global
qemu_aio_context because all callers expect to kick the main loop, not
some other event loop.
Signed-off-by: Stefan Hajnoczi <address@hidden>
---
main-loop.c | 15 +++++++++------
1 file changed, 9 insertions(+), 6 deletions(-)
diff --git a/main-loop.c b/main-loop.c
index 5af3963..5fbdd4a 100644
--- a/main-loop.c
+++ b/main-loop.c
@@ -320,7 +320,9 @@ void qemu_del_wait_object(HANDLE handle, WaitObjectFunc
*func, void *opaque)
void qemu_fd_register(int fd)
{
- WSAEventSelect(fd, event_notifier_get_handle(&qemu_aio_context->notifier),
+ AioContext *ctx = *tls_get_thread_aio_context();
+ HANDLE h = event_notifier_get_handle(&ctx->notifier);
+ WSAEventSelect(fd, h,
FD_READ | FD_ACCEPT | FD_CLOSE |
FD_CONNECT | FD_WRITE | FD_OOB);
}
@@ -478,12 +480,12 @@ int main_loop_wait(int nonblocking)
QEMUBH *qemu_bh_new(QEMUBHFunc *cb, void *opaque)
{
- return aio_bh_new(qemu_aio_context, cb, opaque);
+ return aio_bh_new(*tls_get_thread_aio_context(), cb, opaque);
}
bool qemu_aio_wait(void)
{
- return aio_poll(qemu_aio_context, true);
+ return aio_poll(*tls_get_thread_aio_context(), true);
}
#ifdef CONFIG_POSIX
@@ -493,8 +495,8 @@ void qemu_aio_set_fd_handler(int fd,
AioFlushHandler *io_flush,
void *opaque)
{
- aio_set_fd_handler(qemu_aio_context, fd, io_read, io_write, io_flush,
- opaque);
+ aio_set_fd_handler(*tls_get_thread_aio_context(), fd,
+ io_read, io_write, io_flush, opaque);
}
#endif
@@ -502,5 +504,6 @@ void qemu_aio_set_event_notifier(EventNotifier *notifier,
EventNotifierHandler *io_read,
AioFlushEventNotifierHandler *io_flush)
{
- aio_set_event_notifier(qemu_aio_context, notifier, io_read, io_flush);
+ aio_set_event_notifier(*tls_get_thread_aio_context(), notifier,
+ io_read, io_flush);
}
--
1.8.1.4
- [Qemu-devel] [PATCH v2 00/13] dataplane: use block layer, Stefan Hajnoczi, 2013/07/15
- [Qemu-devel] [PATCH v2 01/13] dataplane: sync virtio.c and vring.c virtqueue state, Stefan Hajnoczi, 2013/07/15
- [Qemu-devel] [PATCH v2 02/13] block: add BlockDevOps->drain_threads_cb(), Stefan Hajnoczi, 2013/07/15
- [Qemu-devel] [PATCH v2 03/13] virtio-blk: implement BlockDevOps->drain_threads_cb(), Stefan Hajnoczi, 2013/07/15
- [Qemu-devel] [PATCH v2 04/13] exec: do not use qemu/tls.h, Stefan Hajnoczi, 2013/07/15
- [Qemu-devel] [PATCH v2 05/13] qemu-thread: add TLS wrappers, Stefan Hajnoczi, 2013/07/15
- [Qemu-devel] [PATCH v2 06/13] block: add thread_aio_context TLS variable, Stefan Hajnoczi, 2013/07/15
- [Qemu-devel] [PATCH v2 07/13] block: drop bdrv_get_aio_context(), Stefan Hajnoczi, 2013/07/15
- [Qemu-devel] [PATCH v2 09/13] linux-aio: bind EventNotifier to current AioContext, Stefan Hajnoczi, 2013/07/15
- [Qemu-devel] [PATCH v2 08/13] main-loop: use thread-local AioContext,
Stefan Hajnoczi <=
- [Qemu-devel] [PATCH v2 10/13] block: disable I/O throttling outside main loop, Stefan Hajnoczi, 2013/07/15
- [Qemu-devel] [PATCH v2 11/13] dataplane: use block layer for I/O, Stefan Hajnoczi, 2013/07/15
- [Qemu-devel] [PATCH v2 12/13] dataplane: drop ioq Linux AIO request queue, Stefan Hajnoczi, 2013/07/15
- [Qemu-devel] [PATCH v2 13/13] block: drop raw_get_aio_fd(), Stefan Hajnoczi, 2013/07/15
- Re: [Qemu-devel] [PATCH v2 00/13] dataplane: use block layer, Paolo Bonzini, 2013/07/15