+
+int td_io_prep(struct thread_data *td, struct io_u *io_u)
+{
+ if (td->io_ops->prep)
+ return td->io_ops->prep(td, io_u);
+
+ return 0;
+}
+
+int td_io_getevents(struct thread_data *td, int min, int max,
+ struct timespec *t)
+{
+ if (td->io_ops->getevents)
+ return td->io_ops->getevents(td, min, max, t);
+
+ return 0;
+}
+
+int td_io_queue(struct thread_data *td, struct io_u *io_u)
+{
+ int ret;
+
+ if (td->io_ops->flags & FIO_SYNCIO)
+ fio_gettime(&io_u->issue_time, NULL);
+
+ if (io_u->ddir != DDIR_SYNC)
+ td->io_issues[io_u->ddir]++;
+
+ ret = td->io_ops->queue(td, io_u);
+
+ if ((td->io_ops->flags & FIO_SYNCIO) == 0)
+ fio_gettime(&io_u->issue_time, NULL);
+
+ return ret;
+}
+
+int td_io_init(struct thread_data *td)
+{
+ if (td->io_ops->init)
+ return td->io_ops->init(td);
+
+ return 0;
+}
+
+int td_io_commit(struct thread_data *td)
+{
+ if (td->io_ops->commit)
+ return td->io_ops->commit(td);
+
+ return 0;
+}