diff options
| author | Jens Axboe <axboe@kernel.dk> | 2021-12-23 07:13:39 -0700 |
|---|---|---|
| committer | Jens Axboe <axboe@kernel.dk> | 2021-12-23 07:13:39 -0700 |
| commit | dbf0855d74b220bc078f248490d4f5489d67f84c (patch) | |
| tree | 6f69c3189cf14713ac719ed9e41538aae64fa000 | |
| parent | 8ecd3fd959634df81d66af8b3a69c16202a014e8 (diff) | |
| parent | deb00f959d436b8d022276daed54e641eed4df42 (diff) | |
| download | liburing-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.c | 2 |
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; } |