#include "../fio.h"
+static int fio_libaio_commit(struct thread_data *td);
+
struct libaio_data {
io_context_t aio_ctx;
struct io_event *aio_events;
};
struct libaio_options {
- struct thread_data *td;
+ void *pad;
unsigned int userspace_reap;
};
r = io_getevents(ld->aio_ctx, actual_min,
max, ld->aio_events + events, lt);
}
- if (r >= 0)
+ if (r > 0)
events += r;
- else if (r == -EAGAIN)
+ else if ((min && r == 0) || r == -EAGAIN) {
+ fio_libaio_commit(td);
usleep(100);
- else
+ } else if (r != -EINTR)
break;
} while (events < min);
}
if (!wait_start) {
fio_gettime(&tv, NULL);
- wait_start = 0;
+ wait_start = 1;
} else if (mtime_since_now(&tv) > 30000) {
log_err("fio: aio appears to be stalled, giving up\n");
break;