a137282786e8759f0c175230a2c45206a814235d
[fio.git] / engines / sync.c
1 /*
2  * sync engine
3  *
4  * IO engine that does regular read(2)/write(2) with lseek(2) to transfer
5  * data.
6  *
7  */
8 #include <stdio.h>
9 #include <stdlib.h>
10 #include <unistd.h>
11 #include <errno.h>
12 #include <assert.h>
13
14 #include "../fio.h"
15 #include "../os.h"
16
17 static int fio_syncio_prep(struct thread_data *td, struct io_u *io_u)
18 {
19         struct fio_file *f = io_u->file;
20
21         if (io_u->ddir == DDIR_SYNC)
22                 return 0;
23         if (io_u->offset == f->last_completed_pos)
24                 return 0;
25
26         if (lseek(f->fd, io_u->offset, SEEK_SET) == -1) {
27                 td_verror(td, errno, "lseek");
28                 return 1;
29         }
30
31         return 0;
32 }
33
34 static int fio_syncio_queue(struct thread_data *td, struct io_u *io_u)
35 {
36         struct fio_file *f = io_u->file;
37         int ret;
38
39         if (io_u->ddir == DDIR_READ)
40                 ret = read(f->fd, io_u->xfer_buf, io_u->xfer_buflen);
41         else if (io_u->ddir == DDIR_WRITE)
42                 ret = write(f->fd, io_u->xfer_buf, io_u->xfer_buflen);
43         else
44                 ret = fsync(f->fd);
45
46         if (ret != (int) io_u->xfer_buflen) {
47                 if (ret >= 0) {
48                         io_u->resid = io_u->xfer_buflen - ret;
49                         io_u->error = 0;
50                         return FIO_Q_COMPLETED;
51                 } else
52                         io_u->error = errno;
53         }
54
55         if (io_u->error)
56                 td_verror(td, io_u->error, "xfer");
57
58         return FIO_Q_COMPLETED;
59 }
60
61 static struct ioengine_ops ioengine = {
62         .name           = "sync",
63         .version        = FIO_IOOPS_VERSION,
64         .prep           = fio_syncio_prep,
65         .queue          = fio_syncio_queue,
66         .open_file      = generic_open_file,
67         .close_file     = generic_close_file,
68         .flags          = FIO_SYNCIO,
69 };
70
71 static void fio_init fio_syncio_register(void)
72 {
73         register_ioengine(&ioengine);
74 }
75
76 static void fio_exit fio_syncio_unregister(void)
77 {
78         unregister_ioengine(&ioengine);
79 }