diff options
| author | Jens Axboe <axboe@kernel.dk> | 2019-08-30 11:09:46 -0600 |
|---|---|---|
| committer | Jens Axboe <axboe@kernel.dk> | 2019-08-30 11:09:46 -0600 |
| commit | b76db3f49d4bae86e299ff8aebfc76996e4c5902 (patch) | |
| tree | 5c6302a4c70d8ba20960989639246160cd9a7312 | |
| parent | ebdbb71160e970af187060dc4bf661af2e5b93b5 (diff) | |
examples/io_uring-cp: handle io_uring_peek_cqe() -EAGAIN
Signed-off-by: Jens Axboe <axboe@kernel.dk>
| -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)); |