If we have pending IOs, commit them.
Signed-off-by: Jens Axboe <axboe@fb.com>
+static int fio_libaio_commit(struct thread_data *td);
+
struct libaio_data {
io_context_t aio_ctx;
struct io_event *aio_events;
struct libaio_data {
io_context_t aio_ctx;
struct io_event *aio_events;
}
if (r >= 0)
events += r;
}
if (r >= 0)
events += r;
+ else if (r == -EAGAIN) {
+ fio_libaio_commit(td);
+ } else if (r != -EINTR)
break;
} while (events < min);
break;
} while (events < min);