- // See if there are any queued reads we can submit now.
- while (!queued_reads.empty() && pending_reads < queue_depth) {
- io_uring_sqe *sqe = io_uring_get_sqe(&ring);
- if (sqe == nullptr) {
- fprintf(stderr, "io_uring_get_sqe: %s\n", strerror(errno));
- exit(1);
- }
- QueuedRead &qr = queued_reads.front();
- submit_read_internal(sqe, qr.fd, qr.len, qr.offset, move(qr.cb));
- queued_reads.pop();
- anything_to_submit = true;
+ // See if there are any queued reads we can submit now.
+ while (!queued_reads.empty() && pending_reads < queue_depth) {
+ io_uring_sqe *sqe = io_uring_get_sqe(&ring);
+ if (sqe == nullptr) {
+ fprintf(stderr, "io_uring_get_sqe: %s\n", strerror(errno));
+ exit(1);