| /external/fio/engines/ |
| glusterfs_async.c | 10 struct io_u *io_u; member in struct:fio_gf_iou
14 static struct io_u *fio_gf_event(struct thread_data *td, int event)
27 struct io_u *io_u; local
32 io_u_qiter(&td->io_u_all, io_u, i) {
35 if (!(io_u->flags & IO_U_F_FLIGHT))
38 io = io_u->engine_data;
41 g->aio_events[events] = io_u;
59 static void fio_gf_io_u_free(struct thread_data *td, struct io_u *io_u
92 struct io_u *io_u = data; local
[all...] |
| glusterfs_sync.c | 11 static int fio_gf_prep(struct thread_data *td, struct io_u *io_u)
13 struct fio_file *f = io_u->file;
18 if (!ddir_rw(io_u->ddir))
21 if (LAST_POS(f) != -1ULL && LAST_POS(f) == io_u->offset)
24 if (glfs_lseek(g->fd, io_u->offset, SEEK_SET) < 0) {
32 static int fio_gf_queue(struct thread_data *td, struct io_u *io_u)
37 dprint(FD_FILE, "fio queue len %lu\n", io_u->xfer_buflen);
38 fio_ro_check(td, io_u);
[all...] |
| sync.c | 25 struct io_u **io_us;
57 static int fio_syncio_prep(struct thread_data *td, struct io_u *io_u)
59 struct fio_file *f = io_u->file;
61 if (!ddir_rw(io_u->ddir))
64 if (LAST_POS(f) != -1ULL && LAST_POS(f) == io_u->offset)
67 if (lseek(f->fd, io_u->offset, SEEK_SET) == -1) {
75 static int fio_io_end(struct thread_data *td, struct io_u *io_u, int ret)
77 if (io_u->file && ret >= 0 && ddir_rw(io_u->ddir)
290 struct io_u *io_u; local
[all...] |
| guasi.c | 37 struct io_u **io_us;
42 static int fio_guasi_prep(struct thread_data fio_unused *td, struct io_u *io_u)
45 GDBG_PRINT(("fio_guasi_prep(%p)\n", io_u));
46 io_u->greq = NULL;
51 static struct io_u *fio_guasi_event(struct thread_data *td, int event)
54 struct io_u *io_u; local
62 io_u = rinf.asid;
63 io_u->error = EINPROGRESS
134 struct io_u *io_u; local
153 struct io_u *io_u; local
[all...] |
| ftruncate.c | 20 static int fio_ftruncate_queue(struct thread_data *td, struct io_u *io_u)
22 struct fio_file *f = io_u->file;
24 fio_ro_check(td, io_u);
26 if (io_u->ddir != DDIR_WRITE) {
27 io_u->error = EINVAL;
30 ret = ftruncate(f->fd, io_u->offset);
33 io_u->error = errno;
|
| mmap.c | 84 static int fio_mmapio_prep_limited(struct thread_data *td, struct io_u *io_u)
86 struct fio_file *f = io_u->file;
89 if (io_u->buflen > mmap_map_size) {
98 fmd->mmap_off = io_u->offset;
106 static int fio_mmapio_prep_full(struct thread_data *td, struct io_u *io_u)
108 struct fio_file *f = io_u->file;
114 if (io_u->offset != (size_t) io_u->offset |
[all...] |
| posixaio.c | 16 struct io_u **aio_events;
64 struct io_u *io_u)
66 struct fio_file *f = io_u->file;
67 int r = aio_cancel(f->fd, &io_u->aiocb);
76 struct io_u *io_u)
78 os_aiocb_t *aiocb = &io_u->aiocb;
79 struct fio_file *f = io_u->file;
82 aiocb->aio_buf = io_u->xfer_buf
101 struct io_u *io_u; local
[all...] |
| solarisaio.c | 16 struct io_u **aio_events;
23 struct io_u *io_u)
25 return aiocancel(&io_u->resultp);
29 struct io_u *io_u)
33 io_u->resultp.aio_return = AIO_INPROGRESS;
34 io_u->engine_data = sd;
41 struct io_u *io_u; local
[all...] |
| splice.c | 29 static int fio_splice_read_old(struct thread_data *td, struct io_u *io_u)
32 struct fio_file *f = io_u->file;
37 offset = io_u->offset;
38 buflen = io_u->xfer_buflen;
39 p = io_u->xfer_buf;
66 return io_u->xfer_buflen;
73 static int fio_splice_read(struct thread_data *td, struct io_u *io_u)
76 struct fio_file *f = io_u->file
[all...] |
| libaio.c | 24 struct io_u **io_us;
70 static int fio_libaio_prep(struct thread_data fio_unused *td, struct io_u *io_u)
72 struct fio_file *f = io_u->file;
74 if (io_u->ddir == DDIR_READ)
75 io_prep_pread(&io_u->iocb, f->fd, io_u->xfer_buf, io_u->xfer_buflen, io_u->offset);
76 else if (io_u->ddir == DDIR_WRITE
88 struct io_u *io_u; local
232 struct io_u *io_u = io_us[i]; local
[all...] |
| dev-dax.c | 103 static int fio_devdax_prep_limited(struct thread_data *td, struct io_u *io_u)
105 struct fio_file *f = io_u->file;
108 if (io_u->buflen > f->real_file_size) {
117 fdd->devdax_off = io_u->offset;
125 static int fio_devdax_prep_full(struct thread_data *td, struct io_u *io_u)
127 struct fio_file *f = io_u->file;
134 if (io_u->offset != (size_t) io_u->offset |
[all...] |
| skeleton_external.c | 24 * The ->event() hook is called to match an event number with an io_u.
29 static struct io_u *fio_skeleton_event(struct thread_data *td, int event)
47 * The ->cancel() hook attempts to cancel the io_u. Only relevant for
50 static int fio_skeleton_cancel(struct thread_data *td, struct io_u *io_u)
56 * The ->queue() hook is responsible for initiating io on the io_u
60 * The io engine must transfer in the direction noted by io_u->ddir
61 * to the buffer pointed to by io_u->xfer_buf for as many bytes as
62 * io_u->xfer_buflen. Residual data count may be set in io_u->resi
[all...] |
| mtd.c | 27 struct io_u *io_u, int eb)
31 ret = mtd_mark_bad(&fmd->info, io_u->file->fd, eb);
33 io_u->error = errno;
43 struct io_u *io_u, int eb)
45 int ret = mtd_is_bad(&fmd->info, io_u->file->fd, eb);
47 io_u->error = errno;
50 io_u->error = EIO; /* Silent failure--don't flood stderr */
54 static int fio_mtd_queue(struct thread_data *td, struct io_u *io_u
[all...] |
| falloc.c | 73 static int fio_fallocate_queue(struct thread_data *td, struct io_u *io_u)
75 struct fio_file *f = io_u->file;
79 fio_ro_check(td, io_u);
81 if (io_u->ddir == DDIR_READ)
83 else if (io_u->ddir == DDIR_WRITE)
85 else if (io_u->ddir == DDIR_TRIM)
88 ret = fallocate(f->fd, flags, io_u->offset, io_u->xfer_buflen);
91 io_u->error = errno
[all...] |
| windowsaio.c | 21 struct io_u *io_u; member in struct:fio_overlapped
26 struct io_u **aio_events;
41 static struct io_u *fio_windowsaio_event(struct thread_data *td, int event);
43 struct io_u *io_u);
62 wd->aio_events = malloc(td->o.iodepth * sizeof(struct io_u*));
257 static struct io_u* fio_windowsaio_event(struct thread_data *td, int event)
269 struct io_u *io_u; local
371 struct io_u *io_u; local
[all...] |
| rbd.c | 23 struct io_u *io_u; member in struct:fio_rbd_iou
36 struct io_u **aio_events;
37 struct io_u **sort_events;
120 rbd->aio_events = calloc(td->o.iodepth, sizeof(struct io_u *));
124 rbd->sort_events = calloc(td->o.iodepth, sizeof(struct io_u *));
283 struct io_u *io_u = fri->io_u; local
293 io_u->error = -ret
361 struct io_u *io_u; local
[all...] |
| e4defrag.c | 134 static int fio_e4defrag_queue(struct thread_data *td, struct io_u *io_u)
140 struct fio_file *f = io_u->file;
144 fio_ro_check(td, io_u);
150 if (io_u->ddir != DDIR_WRITE) {
151 io_u->error = EINVAL;
156 ret = fallocate(ed->donor_fd, 0, io_u->offset, io_u->xfer_buflen);
163 me.orig_start = io_u->offset / ed->bsz;
165 len = (io_u->offset + io_u->xfer_buflen + ed->bsz -1)
[all...] |
| /external/fio/ |
| trim.h | 7 extern bool __must_check get_next_trim(struct thread_data *td, struct io_u *io_u);
8 extern bool io_u_should_trim(struct thread_data *td, struct io_u *io_u);
11 * Determine whether a given io_u should be logged for verify or
23 static inline bool get_next_trim(struct thread_data *td, struct io_u *io_u)
27 static inline bool io_u_should_trim(struct thread_data *td, struct io_u *io_u)
|
| io_u.h | 33 struct io_u { struct
99 int (*end_io)(struct thread_data *, struct io_u **);
130 extern struct io_u *__get_io_u(struct thread_data *);
131 extern struct io_u *get_io_u(struct thread_data *);
132 extern void put_io_u(struct thread_data *, struct io_u *);
133 extern void clear_io_u(struct thread_data *, struct io_u *);
134 extern void requeue_io_u(struct thread_data *, struct io_u **);
135 extern int __must_check io_u_sync_complete(struct thread_data *, struct io_u *);
137 extern void io_u_queued(struct thread_data *, struct io_u *);
139 extern void io_u_log_error(struct thread_data *, struct io_u *);
[all...] |
| io_u_queue.h | 6 struct io_u;
9 struct io_u **io_us;
14 static inline struct io_u *io_u_qpop(struct io_u_queue *q)
18 struct io_u *io_u = q->io_us[next]; local
21 return io_u;
27 static inline void io_u_qpush(struct io_u_queue *q, struct io_u *io_u)
30 q->io_us[q->nr++] = io_u;
42 #define io_u_qiter(q, io_u, i)
72 struct io_u *io_u = r->ring[r->tail]; local
[all...] |
| trim.c | 14 bool get_next_trim(struct thread_data *td, struct io_u *io_u)
19 * this io_u is from a requeue, we already filled the offsets
21 if (io_u->file)
30 io_u->offset = ipo->offset;
31 io_u->buflen = ipo->len;
32 io_u->file = ipo->file;
50 if (!fio_file_open(io_u->file)) {
51 int r = td_io_open_file(td, io_u->file);
55 io_u->file->file_name)
[all...] |
| io_u.c | 38 static void mark_random_map(struct thread_data *td, struct io_u *io_u)
41 struct fio_file *f = io_u->file;
45 block = (io_u->offset - f->file_offset) / (uint64_t) min_bs;
46 nr_blocks = (io_u->buflen + min_bs - 1) / min_bs;
48 if (!(io_u->flags & IO_U_F_BUSY_OK))
51 if ((nr_blocks * min_bs) < io_u->buflen)
52 io_u->buflen = nr_blocks * min_bs;
404 static int get_next_block(struct thread_data *td, struct io_u *io_u,
1451 struct io_u *io_u = NULL; local
1595 struct io_u *io_u; local
1816 struct io_u *io_u = *io_u_ptr; local
1918 struct io_u *io_u; local
[all...] |
| ioengines.h | 7 #include "io_u.h"
27 int (*prep)(struct thread_data *, struct io_u *);
28 int (*queue)(struct thread_data *, struct io_u *);
31 struct io_u *(*event)(struct thread_data *, int);
32 char *(*errdetails)(struct io_u *);
33 int (*cancel)(struct thread_data *, struct io_u *);
43 int (*io_u_init)(struct thread_data *, struct io_u *);
44 void (*io_u_free)(struct thread_data *, struct io_u *);
73 extern int __must_check td_io_prep(struct thread_data *, struct io_u *);
74 extern int __must_check td_io_queue(struct thread_data *, struct io_u *);
[all...] |
| verify.h | 95 extern void populate_verify_io_u(struct thread_data *, struct io_u *);
96 extern int __must_check get_next_verify(struct thread_data *td, struct io_u *);
97 extern int __must_check verify_io_u(struct thread_data *, struct io_u **);
98 extern int verify_io_u_async(struct thread_data *, struct io_u **);
99 extern void fill_verify_pattern(struct thread_data *td, void *p, unsigned int len, struct io_u *io_u, unsigned long seed, int use_seed);
|
| verify.c | 30 static void populate_hdr(struct thread_data *td, struct io_u *io_u,
33 static void fill_hdr(struct thread_data *td, struct io_u *io_u,
36 static void __fill_hdr(struct thread_data *td, struct io_u *io_u,
61 struct io_u *io_u, unsigned long seed, int use_seed)
71 io_u->rand_seed = fill_buffer(td, p, len);
77 if (!td->o.verify_fmt_sz && io_u->buf_filled_len >= len)
228 struct io_u *io_u; member in struct:vcont
301 struct io_u *io_u = vc->io_u; local
377 struct io_u *io_u = vc->io_u; local
738 struct io_u *io_u = *io_u_ptr; local
887 struct io_u *io_u = *io_u_ptr; local
1396 struct io_u *io_u; local
[all...] |
