libio: fix bug in commit hook
[fio.git] / engines / libaio.c
1 /*
2  * libaio engine
3  *
4  * IO engine using the Linux native aio interface.
5  *
6  */
7 #include <stdio.h>
8 #include <stdlib.h>
9 #include <unistd.h>
10 #include <errno.h>
11 #include <assert.h>
12
13 #include "../fio.h"
14
15 #ifdef FIO_HAVE_LIBAIO
16
17 #define ev_to_iou(ev)   (struct io_u *) ((unsigned long) (ev)->obj)
18
19 struct libaio_data {
20         io_context_t aio_ctx;
21         struct io_event *aio_events;
22         struct iocb **iocbs;
23         struct io_u **io_us;
24         int iocbs_nr;
25 };
26
27 static int fio_libaio_prep(struct thread_data fio_unused *td, struct io_u *io_u)
28 {
29         struct fio_file *f = io_u->file;
30
31         if (io_u->ddir == DDIR_READ)
32                 io_prep_pread(&io_u->iocb, f->fd, io_u->xfer_buf, io_u->xfer_buflen, io_u->offset);
33         else if (io_u->ddir == DDIR_WRITE)
34                 io_prep_pwrite(&io_u->iocb, f->fd, io_u->xfer_buf, io_u->xfer_buflen, io_u->offset);
35         else if (io_u->ddir == DDIR_SYNC)
36                 io_prep_fsync(&io_u->iocb, f->fd);
37         else
38                 return 1;
39
40         return 0;
41 }
42
43 static struct io_u *fio_libaio_event(struct thread_data *td, int event)
44 {
45         struct libaio_data *ld = td->io_ops->data;
46         struct io_event *ev;
47         struct io_u *io_u;
48
49         ev = ld->aio_events + event;
50         io_u = ev_to_iou(ev);
51
52         if (ev->res != io_u->xfer_buflen) {
53                 if (ev->res > io_u->xfer_buflen)
54                         io_u->error = -ev->res;
55                 else
56                         io_u->resid = io_u->xfer_buflen - ev->res;
57         } else
58                 io_u->error = 0;
59
60         return io_u;
61 }
62
63 static int fio_libaio_getevents(struct thread_data *td, unsigned int min,
64                                 unsigned int max, struct timespec *t)
65 {
66         struct libaio_data *ld = td->io_ops->data;
67         long r;
68
69         do {
70                 r = io_getevents(ld->aio_ctx, min, max, ld->aio_events, t);
71                 if (r >= min)
72                         break;
73                 else if (r == -EAGAIN) {
74                         usleep(100);
75                         continue;
76                 } else if (r == -EINTR)
77                         continue;
78                 else if (r != 0)
79                         break;
80         } while (1);
81
82         return r;
83 }
84
85 static int fio_libaio_queue(struct thread_data *td, struct io_u *io_u)
86 {
87         struct libaio_data *ld = td->io_ops->data;
88
89         fio_ro_check(td, io_u);
90
91         if (ld->iocbs_nr == (int) td->o.iodepth)
92                 return FIO_Q_BUSY;
93
94         /*
95          * fsync is tricky, since it can fail and we need to do it
96          * serialized with other io. the reason is that linux doesn't
97          * support aio fsync yet. So return busy for the case where we
98          * have pending io, to let fio complete those first.
99          */
100         if (io_u->ddir == DDIR_SYNC) {
101                 if (ld->iocbs_nr)
102                         return FIO_Q_BUSY;
103                 if (fsync(io_u->file->fd) < 0)
104                         io_u->error = errno;
105
106                 return FIO_Q_COMPLETED;
107         }
108
109         ld->iocbs[ld->iocbs_nr] = &io_u->iocb;
110         ld->io_us[ld->iocbs_nr] = io_u;
111         ld->iocbs_nr++;
112         return FIO_Q_QUEUED;
113 }
114
115 static void fio_libaio_queued(struct thread_data *td, struct io_u **io_us,
116                               unsigned int nr)
117 {
118         struct timeval now;
119         unsigned int i;
120
121         fio_gettime(&now, NULL);
122
123         for (i = 0; i < nr; i++) {
124                 struct io_u *io_u = io_us[i];
125
126                 memcpy(&io_u->issue_time, &now, sizeof(now));
127                 io_u_queued(td, io_u);
128         }
129 }
130
131 static int fio_libaio_commit(struct thread_data *td)
132 {
133         struct libaio_data *ld = td->io_ops->data;
134         struct iocb **iocbs;
135         struct io_u **io_us;
136         int ret;
137
138         if (!ld->iocbs_nr)
139                 return 0;
140
141         io_us = ld->io_us;
142         iocbs = ld->iocbs;
143         do {
144                 ret = io_submit(ld->aio_ctx, ld->iocbs_nr, iocbs);
145                 if (ret > 0) {
146                         fio_libaio_queued(td, io_us, ret);
147                         ld->iocbs_nr -= ret;
148                         io_us += ret;
149                         iocbs += ret;
150                         ret = 0;
151                 } else if (!ret || ret == -EAGAIN || ret == -EINTR)
152                         continue;
153                 else
154                         break;
155         } while (ld->iocbs_nr);
156
157         return ret;
158 }
159
160 static int fio_libaio_cancel(struct thread_data *td, struct io_u *io_u)
161 {
162         struct libaio_data *ld = td->io_ops->data;
163
164         return io_cancel(ld->aio_ctx, &io_u->iocb, ld->aio_events);
165 }
166
167 static void fio_libaio_cleanup(struct thread_data *td)
168 {
169         struct libaio_data *ld = td->io_ops->data;
170
171         if (ld) {
172                 io_destroy(ld->aio_ctx);
173                 free(ld->aio_events);
174                 free(ld->iocbs);
175                 free(ld->io_us);
176                 free(ld);
177                 td->io_ops->data = NULL;
178         }
179 }
180
181 static int fio_libaio_init(struct thread_data *td)
182 {
183         struct libaio_data *ld = malloc(sizeof(*ld));
184         static int warn_print;
185         int err;
186
187         if (td->o.iodepth > 1 && !td->o.odirect && !warn_print) {
188                 log_info("fio: libaio engine is only async for non-buffered IO\n");
189                 warn_print = 1;
190         }
191
192         memset(ld, 0, sizeof(*ld));
193
194         err = io_queue_init(td->o.iodepth, &ld->aio_ctx);
195         if (err) {
196                 td_verror(td, -err, "io_queue_init");
197                 free(ld);
198                 return 1;
199         }
200
201         ld->aio_events = malloc(td->o.iodepth * sizeof(struct io_event));
202         memset(ld->aio_events, 0, td->o.iodepth * sizeof(struct io_event));
203         ld->iocbs = malloc(td->o.iodepth * sizeof(struct iocb *));
204         memset(ld->iocbs, 0, sizeof(struct iocb *));
205         ld->io_us = malloc(td->o.iodepth * sizeof(struct io_u *));
206         memset(ld->io_us, 0, td->o.iodepth * sizeof(struct io_u *));
207         ld->iocbs_nr = 0;
208
209         td->io_ops->data = ld;
210         return 0;
211 }
212
213 static struct ioengine_ops ioengine = {
214         .name           = "libaio",
215         .version        = FIO_IOOPS_VERSION,
216         .init           = fio_libaio_init,
217         .prep           = fio_libaio_prep,
218         .queue          = fio_libaio_queue,
219         .commit         = fio_libaio_commit,
220         .cancel         = fio_libaio_cancel,
221         .getevents      = fio_libaio_getevents,
222         .event          = fio_libaio_event,
223         .cleanup        = fio_libaio_cleanup,
224         .open_file      = generic_open_file,
225         .close_file     = generic_close_file,
226 };
227
228 #else /* FIO_HAVE_LIBAIO */
229
230 /*
231  * When we have a proper configure system in place, we simply wont build
232  * and install this io engine. For now install a crippled version that
233  * just complains and fails to load.
234  */
235 static int fio_libaio_init(struct thread_data fio_unused *td)
236 {
237         fprintf(stderr, "fio: libaio not available\n");
238         return 1;
239 }
240
241 static struct ioengine_ops ioengine = {
242         .name           = "libaio",
243         .version        = FIO_IOOPS_VERSION,
244         .init           = fio_libaio_init,
245 };
246
247 #endif
248
249 static void fio_init fio_libaio_register(void)
250 {
251         register_ioengine(&ioengine);
252 }
253
254 static void fio_exit fio_libaio_unregister(void)
255 {
256         unregister_ioengine(&ioengine);
257 }