[PATCH] Remember to check ioops version in loaded module
[fio.git] / engines / fio-engine-mmap.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>
10#include <sys/mman.h>
11#include "fio.h"
12#include "os.h"
13
14struct mmapio_data {
15 struct io_u *last_io_u;
16};
17
18static int fio_mmapio_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_mmapio_event(struct thread_data *td, int event)
34{
35 struct mmapio_data *sd = td->io_ops->data;
36
37 assert(event == 0);
38
39 return sd->last_io_u;
40}
41
42
43static int fio_mmapio_queue(struct thread_data *td, struct io_u *io_u)
44{
45 unsigned long long real_off = io_u->offset - td->file_offset;
46 struct mmapio_data *sd = td->io_ops->data;
47
48 if (io_u->ddir == DDIR_READ)
49 memcpy(io_u->buf, td->mmap + real_off, io_u->buflen);
50 else
51 memcpy(td->mmap + real_off, io_u->buf, io_u->buflen);
52
53 /*
54 * not really direct, but should drop the pages from the cache
55 */
56 if (td->odirect) {
57 if (msync(td->mmap + real_off, io_u->buflen, MS_SYNC) < 0)
58 io_u->error = errno;
59 if (madvise(td->mmap + real_off, io_u->buflen, MADV_DONTNEED) < 0)
60 io_u->error = errno;
61 }
62
63 if (!io_u->error)
64 sd->last_io_u = io_u;
65
66 return io_u->error;
67}
68
69static int fio_mmapio_sync(struct thread_data *td)
70{
71 return msync(td->mmap, td->file_size, MS_SYNC);
72}
73
74static void fio_mmapio_cleanup(struct thread_data *td)
75{
76 if (td->io_ops->data) {
77 free(td->io_ops->data);
78 td->io_ops->data = NULL;
79 }
80}
81
82static int fio_mmapio_init(struct thread_data *td)
83{
84 struct mmapio_data *sd = malloc(sizeof(*sd));
85
86 sd->last_io_u = NULL;
87 td->io_ops->data = sd;
88 return 0;
89}
90
91struct ioengine_ops ioengine = {
92 .name = "mmap",
93 .version = FIO_IOOPS_VERSION,
94 .init = fio_mmapio_init,
95 .queue = fio_mmapio_queue,
96 .getevents = fio_mmapio_getevents,
97 .event = fio_mmapio_event,
98 .cleanup = fio_mmapio_cleanup,
99 .sync = fio_mmapio_sync,
100 .flags = FIO_SYNCIO,
101};