[PATCH] One more round of random map fixes
[fio.git] / engines / sync.c
CommitLineData
2866c82d
JA
1/*
2 * regular read/write sync io engine
3 *
4 */
5#include <stdio.h>
6#include <stdlib.h>
7#include <unistd.h>
8#include <errno.h>
9#include <assert.h>
5f350952
JA
10
11#include "../fio.h"
12#include "../os.h"
2866c82d
JA
13
14struct syncio_data {
15 struct io_u *last_io_u;
16};
17
2866c82d
JA
18static int fio_syncio_getevents(struct thread_data *td, int fio_unused min,
19 int max, struct timespec fio_unused *t)
20{
21 assert(max <= 1);
22
23 /*
24 * we can only have one finished io_u for sync io, since the depth
25 * is always 1
26 */
27 if (list_empty(&td->io_u_busylist))
28 return 0;
29
30 return 1;
31}
32
33static struct io_u *fio_syncio_event(struct thread_data *td, int event)
34{
35 struct syncio_data *sd = td->io_ops->data;
36
37 assert(event == 0);
38
39 return sd->last_io_u;
40}
41
42static int fio_syncio_prep(struct thread_data *td, struct io_u *io_u)
43{
53cdc686
JA
44 struct fio_file *f = io_u->file;
45
87dc1ab1
JA
46 if (io_u->ddir == DDIR_SYNC)
47 return 0;
02bcaa8c
JA
48 if (io_u->offset == f->last_completed_pos)
49 return 0;
87dc1ab1 50
53cdc686 51 if (lseek(f->fd, io_u->offset, SEEK_SET) == -1) {
2866c82d
JA
52 td_verror(td, errno);
53 return 1;
54 }
55
56 return 0;
57}
58
59static int fio_syncio_queue(struct thread_data *td, struct io_u *io_u)
60{
61 struct syncio_data *sd = td->io_ops->data;
53cdc686 62 struct fio_file *f = io_u->file;
cec6b55d 63 int ret;
2866c82d
JA
64
65 if (io_u->ddir == DDIR_READ)
cec6b55d 66 ret = read(f->fd, io_u->xfer_buf, io_u->xfer_buflen);
87dc1ab1 67 else if (io_u->ddir == DDIR_WRITE)
cec6b55d 68 ret = write(f->fd, io_u->xfer_buf, io_u->xfer_buflen);
87dc1ab1
JA
69 else
70 ret = fsync(f->fd);
2866c82d 71
cec6b55d 72 if (ret != (int) io_u->xfer_buflen) {
2866c82d 73 if (ret > 0) {
cec6b55d
JA
74 io_u->resid = io_u->xfer_buflen - ret;
75 io_u->error = 0;
76 return ret;
2866c82d
JA
77 } else
78 io_u->error = errno;
79 }
80
81 if (!io_u->error)
82 sd->last_io_u = io_u;
95bcd815
JA
83 else
84 td_verror(td, io_u->error);
2866c82d
JA
85
86 return io_u->error;
87}
88
89static void fio_syncio_cleanup(struct thread_data *td)
90{
91 if (td->io_ops->data) {
92 free(td->io_ops->data);
93 td->io_ops->data = NULL;
94 }
95}
96
97static int fio_syncio_init(struct thread_data *td)
98{
99 struct syncio_data *sd = malloc(sizeof(*sd));
100
101 sd->last_io_u = NULL;
102 td->io_ops->data = sd;
103 return 0;
104}
105
5f350952 106static struct ioengine_ops ioengine = {
2866c82d
JA
107 .name = "sync",
108 .version = FIO_IOOPS_VERSION,
109 .init = fio_syncio_init,
110 .prep = fio_syncio_prep,
111 .queue = fio_syncio_queue,
112 .getevents = fio_syncio_getevents,
113 .event = fio_syncio_event,
114 .cleanup = fio_syncio_cleanup,
2866c82d
JA
115 .flags = FIO_SYNCIO,
116};
5f350952
JA
117
118static void fio_init fio_syncio_register(void)
119{
120 register_ioengine(&ioengine);
121}
122
123static void fio_exit fio_syncio_unregister(void)
124{
125 unregister_ioengine(&ioengine);
126}