| /external/fio/ |
| io_u_queue.h | 6 struct io_u;
9 struct io_u **io_us;
13 static inline struct io_u *io_u_qpop(struct io_u_queue *q)
21 static inline void io_u_qpush(struct io_u_queue *q, struct io_u *io_u)
23 q->io_us[q->nr++] = io_u;
31 #define io_u_qiter(q, io_u, i) \
32 for (i = 0; i < (q)->nr && (io_u = (q)->io_us[i]); i++)
41 struct io_u **ring;
47 static inline void io_u_rpush(struct io_u_ring *r, struct io_u *io_u
61 struct io_u *io_u = r->ring[r->tail]; local
[all...] |
| ioengine.h | 34 struct io_u { struct
93 int (*end_io)(struct thread_data *, struct io_u *);
137 int (*prep)(struct thread_data *, struct io_u *);
138 int (*queue)(struct thread_data *, struct io_u *);
141 struct io_u *(*event)(struct thread_data *, int);
142 int (*cancel)(struct thread_data *, struct io_u *);
148 int (*io_u_init)(struct thread_data *, struct io_u *);
149 void (*io_u_free)(struct thread_data *, struct io_u *);
179 extern int __must_check td_io_prep(struct thread_data *, struct io_u *);
180 extern int __must_check td_io_queue(struct thread_data *, struct io_u *);
[all...] |
| verify.c | 28 static void populate_hdr(struct thread_data *td, struct io_u *io_u,
68 struct io_u *io_u, unsigned long seed, int use_seed)
76 io_u->rand_seed = fill_random_buf(&td->__verify_state, p, len);
80 if (io_u->buf_filled_len >= len) {
88 io_u->buf_filled_len = len;
91 static unsigned int get_hdr_inc(struct thread_data *td, struct io_u *io_u)
95 hdr_inc = io_u->buflen
216 struct io_u *io_u; member in struct:vcont
286 struct io_u *io_u = vc->io_u; local
349 struct io_u *io_u = vc->io_u; local
395 struct io_u *io_u = vc->io_u; local
1169 struct io_u *io_u; local
[all...] |
| backend.c | 262 struct io_u *io_u; local
265 io_u_qiter(&td->io_u_all, io_u, i) {
266 if (io_u->flags & IO_U_F_FLIGHT) {
267 r = td->io_ops->cancel(td, io_u);
269 put_io_u(td, io_u);
284 struct io_u *io_u = __get_io_u(td); local
287 if (!io_u)
290 io_u->ddir = DDIR_SYNC
425 struct io_u *io_u; local
702 struct io_u *io_u; local
961 struct io_u *io_u; local
980 struct io_u *io_u; local
1221 struct io_u *io_u; local
[all...] |
| io_u.c | 36 static void mark_random_map(struct thread_data *td, struct io_u *io_u)
39 struct fio_file *f = io_u->file;
43 block = (io_u->offset - f->file_offset) / (uint64_t) min_bs;
44 nr_blocks = (io_u->buflen + min_bs - 1) / min_bs;
46 if (!(io_u->flags & IO_U_F_BUSY_OK))
49 if ((nr_blocks * min_bs) < io_u->buflen)
50 io_u->buflen = nr_blocks * min_bs;
296 static int get_next_block(struct thread_data *td, struct io_u *io_u,
1298 struct io_u *io_u = NULL; local
1437 struct io_u *io_u; local
1735 struct io_u *io_u; local
[all...] |
| /external/fio/engines/ |
| 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...] |
| 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...] |
| 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...] |
| sync.c | 24 struct io_u **io_us;
34 static int fio_syncio_prep(struct thread_data *td, struct io_u *io_u)
36 struct fio_file *f = io_u->file;
38 if (!ddir_rw(io_u->ddir))
41 if (LAST_POS(f) != -1ULL && LAST_POS(f) == io_u->offset)
44 if (lseek(f->fd, io_u->offset, SEEK_SET) == -1) {
52 static int fio_io_end(struct thread_data *td, struct io_u *io_u, int ret)
54 if (io_u->file && ret >= 0 && ddir_rw(io_u->ddir)
233 struct io_u *io_u; local
[all...] |
| libaio.c | 20 struct io_u **io_us;
44 static int fio_libaio_prep(struct thread_data fio_unused *td, struct io_u *io_u)
46 struct fio_file *f = io_u->file;
48 if (io_u->ddir == DDIR_READ)
49 io_prep_pread(&io_u->iocb, f->fd, io_u->xfer_buf, io_u->xfer_buflen, io_u->offset);
50 else if (io_u->ddir == DDIR_WRITE
62 struct io_u *io_u; local
196 struct io_u *io_u = io_us[i]; local
[all...] |
| rbd.c | 13 struct io_u *io_u; member in struct:fio_rbd_iou
21 struct io_u **aio_events;
78 rbd_data->aio_events = malloc(td->o.iodepth * sizeof(struct io_u *));
82 memset(rbd_data->aio_events, 0, td->o.iodepth * sizeof(struct io_u *));
164 struct io_u *io_u = (struct io_u *)data; local
166 (struct fio_rbd_iou *)io_u->engine_data;
181 struct io_u *io_u = (struct io_u *)data local
208 struct io_u *io_u; local
[all...] |
| sg.c | 25 struct io_u **events;
34 struct io_u *io_u, int fs)
36 struct sgio_cmd *sc = &sd->cmds[io_u->index];
44 hdr->pack_id = io_u->index;
45 hdr->usr_ptr = io_u;
48 hdr->dxferp = io_u->xfer_buf;
49 hdr->dxfer_len = io_u->xfer_buflen;
160 struct fio_file *f, struct io_u *io_u)
283 struct io_u io_u; local
[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*));
252 static struct io_u* fio_windowsaio_event(struct thread_data *td, int event)
263 struct io_u *io_u; local
367 struct io_u *io_u; local
[all...] |
| rdma.c | 109 struct io_u **io_us_queued;
111 struct io_u **io_us_flight;
113 struct io_u **io_us_completed;
466 static int fio_rdmaio_prep(struct thread_data *td, struct io_u *io_u)
471 r_io_u_d = io_u->engine_data;
476 r_io_u_d->rdma_sgl.addr = (uint64_t) (unsigned long)io_u->buf;
477 r_io_u_d->rdma_sgl.lkey = io_u->mr->lkey;
484 r_io_u_d->rdma_sgl.addr = (uint64_t) (unsigned long)io_u->buf;
485 r_io_u_d->rdma_sgl.lkey = io_u->mr->lkey
512 struct io_u *io_u; local
718 struct io_u *io_u = io_us[i]; local
1156 struct io_u *io_u = td->io_u_freelist.io_us[i]; local
[all...] |
