log_err("%s: no getevents handler\n", ops->name);
return 1;
}
- if (!ops->queue) {
- log_err("%s: no queue handler\n", ops->name);
- return 1;
- }
return 0;
}
} else if (ret == FIO_Q_QUEUED) {
int r;
- if (ddir_rw(io_u->ddir)) {
- td->io_u_queued++;
+ td->io_u_queued++;
+
+ if (ddir_rw(io_u->ddir))
td->ts.total_io_u[io_u->ddir]++;
- }
if (td->io_u_queued >= td->o.iodepth_batch) {
r = td_io_commit(td);