From b76db3f49d4bae86e299ff8aebfc76996e4c5902 Mon Sep 17 00:00:00 2001 From: Jens Axboe Date: Fri, 30 Aug 2019 11:09:46 -0600 Subject: examples/io_uring-cp: handle io_uring_peek_cqe() -EAGAIN Signed-off-by: Jens Axboe --- examples/io_uring-cp.c | 7 ++++++- 1 file changed, 6 insertions(+), 1 deletion(-) diff --git a/examples/io_uring-cp.c b/examples/io_uring-cp.c index adb7b29..455ca72 100644 --- a/examples/io_uring-cp.c +++ b/examples/io_uring-cp.c @@ -168,8 +168,13 @@ static int copy_file(struct io_uring *ring, off_t insize) if (!got_comp) { ret = io_uring_wait_cqe(ring, &cqe); got_comp = 1; - } else + } else { ret = io_uring_peek_cqe(ring, &cqe); + if (ret == -EAGAIN) { + cqe = NULL; + ret = 0; + } + } if (ret < 0) { fprintf(stderr, "io_uring_peek_cqe: %s\n", strerror(-ret)); -- cgit