diff --git a/lib/bdev/uring/bdev_uring.c b/lib/bdev/uring/bdev_uring.c index 97ee8449f..743c881c8 100644 --- a/lib/bdev/uring/bdev_uring.c +++ b/lib/bdev/uring/bdev_uring.c @@ -206,7 +206,7 @@ bdev_uring_reap(struct io_uring *ring, int max) count = 0; for (i = 0; i < max; i++) { - ret = io_uring_get_completion(ring, &cqe); + ret = io_uring_peek_cqe(ring, &cqe); if (ret != 0) { return ret; } @@ -223,6 +223,7 @@ bdev_uring_reap(struct io_uring *ring, int max) } uring_task->ch->group_ch->io_inflight--; + io_uring_cqe_seen(ring, cqe); spdk_bdev_io_complete(spdk_bdev_io_from_ctx(uring_task), status); count++; }