struct fio_file *f = io_u->file;
int r = aio_cancel(f->fd, &io_u->aiocb);
struct fio_file *f = io_u->file;
int r = aio_cancel(f->fd, &io_u->aiocb);
static int fio_posixaio_getevents(struct thread_data *td, unsigned int min,
unsigned int max, struct timespec *t)
{
struct posixaio_data *pd = td->io_ops->data;
static int fio_posixaio_getevents(struct thread_data *td, unsigned int min,
unsigned int max, struct timespec *t)
{
struct posixaio_data *pd = td->io_ops->data;
- list_for_each(entry, &td->io_u_busylist) {
- struct io_u *io_u = list_entry(entry, struct io_u, list);
+ flist_for_each(entry, &td->io_u_busylist) {
+ struct io_u *io_u = flist_entry(entry, struct io_u, list);
- * hrmpf, we need to wait for more. we should use aio_suspend, for
- * now just sleep a little and recheck status of busy-and-not-seen
+ * must have some in-flight, wait for at least one
.cleanup = fio_posixaio_cleanup,
.open_file = generic_open_file,
.close_file = generic_close_file,
.cleanup = fio_posixaio_cleanup,
.open_file = generic_open_file,
.close_file = generic_close_file,