diff options
| -rw-r--r-- | examples/io_uring-cp.c | 7 |
1 files changed, 6 insertions, 1 deletions
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)); |