else if (io_u->ddir == DDIR_WRITE)
ret = pwrite(f->fd, io_u->xfer_buf, io_u->xfer_buflen, io_u->offset);
else
else if (io_u->ddir == DDIR_WRITE)
ret = pwrite(f->fd, io_u->xfer_buf, io_u->xfer_buflen, io_u->offset);
else
else if (io_u->ddir == DDIR_WRITE)
ret = write(f->fd, io_u->xfer_buf, io_u->xfer_buflen);
else
else if (io_u->ddir == DDIR_WRITE)
ret = write(f->fd, io_u->xfer_buf, io_u->xfer_buflen);
else
- if (io_u->ddir == DDIR_SYNC) {
- int ret = fsync(io_u->file->fd);
+ if (ddir_sync(io_u->ddir)) {
+ int ret = do_io_u_sync(td, io_u);
.queue = fio_syncio_queue,
.open_file = generic_open_file,
.close_file = generic_close_file,
.queue = fio_syncio_queue,
.open_file = generic_open_file,
.close_file = generic_close_file,
.queue = fio_psyncio_queue,
.open_file = generic_open_file,
.close_file = generic_close_file,
.queue = fio_psyncio_queue,
.open_file = generic_open_file,
.close_file = generic_close_file,
.getevents = fio_vsyncio_getevents,
.open_file = generic_open_file,
.close_file = generic_close_file,
.getevents = fio_vsyncio_getevents,
.open_file = generic_open_file,
.close_file = generic_close_file,