aboutsummaryrefslogtreecommitdiff
path: root/block
diff options
context:
space:
mode:
authorStefano Garzarella <sgarzare@redhat.com>2020-05-19 15:49:42 +0200
committerStefan Hajnoczi <stefanha@redhat.com>2020-06-05 09:54:48 +0100
commit769335ecb1e8fd9c4317bdff7cfd0f84af7ab2f9 (patch)
treec667fe833c5a1beece4221e808f7e8383f28ae57 /block
parentb4e44c9944e19c8bfc7fbf0c4a6a5e48f3ba3dc0 (diff)
downloadqemu-769335ecb1e8fd9c4317bdff7cfd0f84af7ab2f9.zip
qemu-769335ecb1e8fd9c4317bdff7cfd0f84af7ab2f9.tar.gz
qemu-769335ecb1e8fd9c4317bdff7cfd0f84af7ab2f9.tar.bz2
io_uring: use io_uring_cq_ready() to check for ready cqes
In qemu_luring_poll_cb() we are not using the cqe peeked from the CQ ring. We are using io_uring_peek_cqe() only to see if there are cqes ready, so we can replace it with io_uring_cq_ready(). Signed-off-by: Stefano Garzarella <sgarzare@redhat.com> Message-id: 20200519134942.118178-1-sgarzare@redhat.com Signed-off-by: Stefan Hajnoczi <stefanha@redhat.com>
Diffstat (limited to 'block')
-rw-r--r--block/io_uring.c9
1 files changed, 3 insertions, 6 deletions
diff --git a/block/io_uring.c b/block/io_uring.c
index 9765681..037af09 100644
--- a/block/io_uring.c
+++ b/block/io_uring.c
@@ -277,13 +277,10 @@ static void qemu_luring_completion_cb(void *opaque)
static bool qemu_luring_poll_cb(void *opaque)
{
LuringState *s = opaque;
- struct io_uring_cqe *cqes;
- if (io_uring_peek_cqe(&s->ring, &cqes) == 0) {
- if (cqes) {
- luring_process_completions_and_submit(s);
- return true;
- }
+ if (io_uring_cq_ready(&s->ring)) {
+ luring_process_completions_and_submit(s);
+ return true;
}
return false;