+static int fio_io_end(struct thread_data *td, struct io_u *io_u, int ret)
+{
+ if (io_u->file && ret >= 0 && ddir_rw(io_u->ddir))
+ LAST_POS(io_u->file) = io_u->offset + ret;
+
+ if (ret != (int) io_u->xfer_buflen) {
+ if (ret >= 0) {
+ io_u->resid = io_u->xfer_buflen - ret;
+ io_u->error = 0;
+ return FIO_Q_COMPLETED;
+ } else
+ io_u->error = errno;
+ }
+
+ if (io_u->error) {
+ io_u_log_error(td, io_u);
+ td_verror(td, io_u->error, "xfer");
+ }
+
+ return FIO_Q_COMPLETED;
+}
+
+#ifdef CONFIG_PWRITEV
+static enum fio_q_status fio_pvsyncio_queue(struct thread_data *td,
+ struct io_u *io_u)
+{
+ struct syncio_data *sd = td->io_ops_data;
+ struct iovec *iov = &sd->iovecs[0];
+ struct fio_file *f = io_u->file;
+ int ret;
+
+ fio_ro_check(td, io_u);
+
+ iov->iov_base = io_u->xfer_buf;
+ iov->iov_len = io_u->xfer_buflen;
+
+ if (io_u->ddir == DDIR_READ)
+ ret = preadv(f->fd, iov, 1, io_u->offset);
+ else if (io_u->ddir == DDIR_WRITE)
+ ret = pwritev(f->fd, iov, 1, io_u->offset);
+ else if (io_u->ddir == DDIR_TRIM) {
+ do_io_u_trim(td, io_u);
+ return FIO_Q_COMPLETED;
+ } else
+ ret = do_io_u_sync(td, io_u);
+
+ return fio_io_end(td, io_u, ret);
+}
+#endif
+
+#ifdef FIO_HAVE_PWRITEV2
+static enum fio_q_status fio_pvsyncio2_queue(struct thread_data *td,
+ struct io_u *io_u)
+{
+ struct syncio_data *sd = td->io_ops_data;
+ struct psyncv2_options *o = td->eo;
+ struct iovec *iov = &sd->iovecs[0];
+ struct fio_file *f = io_u->file;
+ int ret, flags = 0;
+
+ fio_ro_check(td, io_u);
+
+ if (o->hipri &&
+ (rand_between(&sd->rand_state, 1, 100) <= o->hipri_percentage))
+ flags |= RWF_HIPRI;
+
+ iov->iov_base = io_u->xfer_buf;
+ iov->iov_len = io_u->xfer_buflen;
+
+ if (io_u->ddir == DDIR_READ)
+ ret = preadv2(f->fd, iov, 1, io_u->offset, flags);
+ else if (io_u->ddir == DDIR_WRITE)
+ ret = pwritev2(f->fd, iov, 1, io_u->offset, flags);
+ else if (io_u->ddir == DDIR_TRIM) {
+ do_io_u_trim(td, io_u);
+ return FIO_Q_COMPLETED;
+ } else
+ ret = do_io_u_sync(td, io_u);
+
+ return fio_io_end(td, io_u, ret);
+}
+#endif
+
+static enum fio_q_status fio_psyncio_queue(struct thread_data *td,
+ struct io_u *io_u)
+{
+ struct fio_file *f = io_u->file;
+ int ret;
+
+ fio_ro_check(td, io_u);
+
+ if (io_u->ddir == DDIR_READ)
+ ret = pread(f->fd, io_u->xfer_buf, io_u->xfer_buflen, io_u->offset);
+ else if (io_u->ddir == DDIR_WRITE)
+ ret = pwrite(f->fd, io_u->xfer_buf, io_u->xfer_buflen, io_u->offset);
+ else if (io_u->ddir == DDIR_TRIM) {
+ do_io_u_trim(td, io_u);
+ return FIO_Q_COMPLETED;
+ } else
+ ret = do_io_u_sync(td, io_u);
+
+ return fio_io_end(td, io_u, ret);
+}
+
+static enum fio_q_status fio_syncio_queue(struct thread_data *td,
+ struct io_u *io_u)