summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorJens Axboe <axboe@kernel.dk>2021-12-23 07:13:39 -0700
committerJens Axboe <axboe@kernel.dk>2021-12-23 07:13:39 -0700
commitdbf0855d74b220bc078f248490d4f5489d67f84c (patch)
tree6f69c3189cf14713ac719ed9e41538aae64fa000
parent8ecd3fd959634df81d66af8b3a69c16202a014e8 (diff)
parentdeb00f959d436b8d022276daed54e641eed4df42 (diff)
downloadliburing-dbf0855d74b220bc078f248490d4f5489d67f84c.tar.gz
liburing-dbf0855d74b220bc078f248490d4f5489d67f84c.tar.bz2
Merge branch 'issue503' of https://github.com/aprilweet/liburing
* 'issue503' of https://github.com/aprilweet/liburing: examples/io_uring_cp: fix bug while re-queuing
-rw-r--r--examples/io_uring-cp.c2
1 files changed, 2 insertions, 0 deletions
diff --git a/examples/io_uring-cp.c b/examples/io_uring-cp.c
index 9322575..43444d8 100644
--- a/examples/io_uring-cp.c
+++ b/examples/io_uring-cp.c
@@ -189,6 +189,7 @@ static int copy_file(struct io_uring *ring, off_t insize)
if (cqe->res < 0) {
if (cqe->res == -EAGAIN) {
queue_prepped(ring, data);
+ io_uring_submit(ring);
io_uring_cqe_seen(ring, cqe);
continue;
}
@@ -201,6 +202,7 @@ static int copy_file(struct io_uring *ring, off_t insize)
data->iov.iov_len -= cqe->res;
data->offset += cqe->res;
queue_prepped(ring, data);
+ io_uring_submit(ring);
io_uring_cqe_seen(ring, cqe);
continue;
}