/external/fio/ |
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...] |
rate-submit.c | 15 struct io_u *io_u = container_of(work, struct io_u, work); local 16 const enum fio_ddir ddir = io_u->ddir; 20 dprint(FD_RATE, "io_u %p queued by %u\n", io_u, gettid()); 22 io_u_set(td, io_u, IO_U_F_NO_FILE_PUT); 27 ret = td_io_queue(td, io_u); 33 io_u_clear(td, io_u, IO_U_F_FLIGHT); 36 dprint(FD_RATE, "io_u %p ret %d by %u\n", io_u, ret, gettid()) [all...] |
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...] |
backend.c | 259 struct io_u *io_u; local 262 io_u_qiter(&td->io_u_all, io_u, i) { 263 if (io_u->flags & IO_U_F_FLIGHT) { 264 r = td->io_ops->cancel(td, io_u); 266 put_io_u(td, io_u); 281 struct io_u *io_u = __get_io_u(td); local 284 if (!io_u) 287 io_u->ddir = DDIR_SYNC 596 struct io_u *io_u; local 878 struct io_u *io_u; local 1126 struct io_u *io_u; local 1147 struct io_u *io_u; local 1411 struct io_u *io_u; local [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...] |
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...] |
/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...] |
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...] |
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...] |
sg.c | 30 struct io_u **events; 39 struct io_u *io_u, int fs) 41 struct sgio_cmd *sc = &sd->cmds[io_u->index]; 51 hdr->pack_id = io_u->index; 52 hdr->usr_ptr = io_u; 55 hdr->dxferp = io_u->xfer_buf; 56 hdr->dxfer_len = io_u->xfer_buflen; 185 struct io_u *io_u; local [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...] |
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...] |
rdma.c | 182 struct io_u **io_us_queued; 184 struct io_u **io_us_flight; 186 struct io_u **io_us_completed; 562 static int fio_rdmaio_prep(struct thread_data *td, struct io_u *io_u) 567 r_io_u_d = io_u->engine_data; 572 r_io_u_d->rdma_sgl.addr = (uint64_t) (unsigned long)io_u->buf; 573 r_io_u_d->rdma_sgl.lkey = io_u->mr->lkey; 580 r_io_u_d->rdma_sgl.addr = (uint64_t) (unsigned long)io_u->buf; 581 r_io_u_d->rdma_sgl.lkey = io_u->mr->lkey 608 struct io_u *io_u; local 814 struct io_u *io_u = io_us[i]; local 1287 struct io_u *io_u = td->io_u_freelist.io_us[i]; local [all...] |