return nd->io_us[event];
}
-static int fio_null_getevents(struct thread_data *td, int min_events,
- int fio_unused max, struct timespec fio_unused *t)
+static int fio_null_getevents(struct thread_data *td, unsigned int min_events,
+ unsigned int fio_unused max,
+ struct timespec fio_unused *t)
{
struct null_data *nd = td->io_ops->data;
int ret = 0;
struct null_data *nd = td->io_ops->data;
if (!nd->events) {
+ io_u_mark_submit(td, nd->queued);
nd->events = nd->queued;
nd->queued = 0;
}
{
struct null_data *nd = td->io_ops->data;
+ fio_ro_check(td, io_u);
+
if (td->io_ops->flags & FIO_SYNCIO)
return FIO_Q_COMPLETED;
if (nd->events)
if (nd->io_us)
free(nd->io_us);
free(nd);
- td->io_ops->data = NULL;
}
}