diff options
author | Stefan Hajnoczi <stefanha@redhat.com> | 2016-12-01 19:26:40 +0000 |
---|---|---|
committer | Stefan Hajnoczi <stefanha@redhat.com> | 2017-01-03 16:38:47 +0000 |
commit | 721671ade77f4046b45893fbb7864ca84b9504cd (patch) | |
tree | 46a5e927a01342c5818e6ba99f137a6ad6fbb9f8 /aio-posix.c | |
parent | 0891ee111217101bce683e30ed9f08cf0cfcffd7 (diff) | |
download | qemu-721671ade77f4046b45893fbb7864ca84b9504cd.zip qemu-721671ade77f4046b45893fbb7864ca84b9504cd.tar.gz qemu-721671ade77f4046b45893fbb7864ca84b9504cd.tar.bz2 |
aio: add flag to skip fds to aio_dispatch()
Polling mode will not call ppoll(2)/epoll_wait(2). Therefore we know
there are no fds ready and should avoid looping over fd handlers in
aio_dispatch().
Signed-off-by: Stefan Hajnoczi <stefanha@redhat.com>
Reviewed-by: Paolo Bonzini <pbonzini@redhat.com>
Message-id: 20161201192652.9509-2-stefanha@redhat.com
Signed-off-by: Stefan Hajnoczi <stefanha@redhat.com>
Diffstat (limited to 'aio-posix.c')
-rw-r--r-- | aio-posix.c | 14 |
1 files changed, 10 insertions, 4 deletions
diff --git a/aio-posix.c b/aio-posix.c index e13b9ab..4ac2346 100644 --- a/aio-posix.c +++ b/aio-posix.c @@ -290,9 +290,13 @@ bool aio_pending(AioContext *ctx) return false; } -bool aio_dispatch(AioContext *ctx) +/* + * Note that dispatch_fds == false has the side-effect of post-poning the + * freeing of deleted handlers. + */ +bool aio_dispatch(AioContext *ctx, bool dispatch_fds) { - AioHandler *node; + AioHandler *node = NULL; bool progress = false; /* @@ -308,7 +312,9 @@ bool aio_dispatch(AioContext *ctx) * We have to walk very carefully in case aio_set_fd_handler is * called while we're walking. */ - node = QLIST_FIRST(&ctx->aio_handlers); + if (dispatch_fds) { + node = QLIST_FIRST(&ctx->aio_handlers); + } while (node) { AioHandler *tmp; int revents; @@ -473,7 +479,7 @@ bool aio_poll(AioContext *ctx, bool blocking) ctx->walking_handlers--; /* Run dispatch even if there were no readable fds to run timers */ - if (aio_dispatch(ctx)) { + if (aio_dispatch(ctx, ret > 0)) { progress = true; } |