/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) 17 struct io_u *io_u = q->io_us[next]; local 20 return io_u; 26 static inline void io_u_qpush(struct io_u_queue *q, struct io_u *io_u) 28 q->io_us[q->nr++] = io_u; 36 #define io_u_qiter(q, io_u, i) 66 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 *); 150 int (*io_u_init)(struct thread_data *, struct io_u *); 151 void (*io_u_free)(struct thread_data *, struct io_u *); 182 extern int __must_check td_io_prep(struct thread_data *, struct io_u *); 183 extern int __must_check td_io_queue(struct thread_data *, struct io_u *); [all...] |
backend.c | 266 struct io_u *io_u; local 269 io_u_qiter(&td->io_u_all, io_u, i) { 270 if (io_u->flags & IO_U_F_FLIGHT) { 271 r = td->io_ops->cancel(td, io_u); 273 put_io_u(td, io_u); 288 struct io_u *io_u = __get_io_u(td); local 291 if (!io_u) 294 io_u->ddir = DDIR_SYNC 457 struct io_u *io_u; local 751 struct io_u *io_u; local 995 struct io_u *io_u; local 1017 struct io_u *io_u; local 1266 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; 299 static int get_next_block(struct thread_data *td, struct io_u *io_u, 1293 struct io_u *io_u = NULL; local 1435 struct io_u *io_u; local 1607 struct io_u *io_u = *io_u_ptr; local 1741 struct io_u *io_u; local [all...] |
verify.c | 28 static void populate_hdr(struct thread_data *td, struct io_u *io_u, 52 struct io_u *io_u, unsigned long seed, int use_seed) 62 io_u->rand_seed = fill_buffer(td, p, len); 66 if (io_u->buf_filled_len >= len) { 73 io_u->buf_filled_len = len; 76 static unsigned int get_hdr_inc(struct thread_data *td, struct io_u *io_u) 80 hdr_inc = io_u->buflen 201 struct io_u *io_u; member in struct:vcont 271 struct io_u *io_u = vc->io_u; local 334 struct io_u *io_u = vc->io_u; local 380 struct io_u *io_u = vc->io_u; local 650 struct io_u *io_u = *io_u_ptr; local 744 struct io_u *io_u = *io_u_ptr; local 1157 struct io_u *io_u; local [all...] |
/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...] |
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) 235 struct io_u *io_u; local [all...] |
libaio.c | 22 struct io_u **io_us; 68 static int fio_libaio_prep(struct thread_data fio_unused *td, struct io_u *io_u) 70 struct fio_file *f = io_u->file; 72 if (io_u->ddir == DDIR_READ) 73 io_prep_pread(&io_u->iocb, f->fd, io_u->xfer_buf, io_u->xfer_buflen, io_u->offset); 74 else if (io_u->ddir == DDIR_WRITE 86 struct io_u *io_u; local 230 struct io_u *io_u = io_us[i]; local [all...] |
rbd.c | 13 struct io_u *io_u; member in struct:fio_rbd_iou 23 struct io_u **aio_events; 24 struct io_u **sort_events; 90 rbd->aio_events = calloc(td->o.iodepth, sizeof(struct io_u *)); 94 rbd->sort_events = calloc(td->o.iodepth, sizeof(struct io_u *)); 180 struct io_u *io_u = fri->io_u; local 192 io_u->error = ret 258 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; 161 struct fio_file *f, struct io_u *io_u) 284 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) 264 struct io_u *io_u; local 368 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...] |