/external/fio/ |
ioengines.c | 191 int td_io_prep(struct thread_data *td, struct io_u *io_u) 193 dprint_io_u(io_u, "prep"); 194 fio_ro_check(td, io_u); 196 lock_file(td, io_u->file, io_u->ddir); 199 int ret = td->io_ops->prep(td, io_u); 201 dprint(FD_IO, "->prep(%p)=%d\n", io_u, ret); 203 unlock_file(td, io_u->file); 253 int td_io_queue(struct thread_data *td, struct io_u *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...] |
profile.h | 7 * Functions for overriding internal fio io_u functions 13 int (*fill_io_u_off)(struct thread_data *, struct io_u *, unsigned int *); 14 int (*fill_io_u_size)(struct thread_data *, struct io_u *, unsigned int);
|
io_u_queue.c | 6 q->io_us = calloc(nr, sizeof(struct io_u *)); 33 ring->ring = calloc(ring->max, sizeof(struct io_u *));
|
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...] |
iolog.h | 193 * When logging io actions, this matches a single sent io_u 226 struct io_u; 227 extern int __must_check read_iolog_get(struct thread_data *, struct io_u *); 228 extern void log_io_u(const struct thread_data *, const struct io_u *); 231 extern void log_io_piece(struct thread_data *, struct io_u *); 232 extern void unlog_io_piece(struct thread_data *, struct io_u *); 233 extern void trim_io_piece(struct thread_data *, const struct io_u *);
|
iolog.c | 33 void log_io_u(const struct thread_data *td, const struct io_u *io_u) 38 fprintf(td->iolog_f, "%s %s %llu %lu\n", io_u->file->file_name, 39 io_ddir_name(io_u->ddir), 40 io_u->offset, io_u->buflen); 136 int read_iolog_get(struct thread_data *td, struct io_u *io_u) 157 io_u->ddir = ipo->ddir; 159 io_u->offset = ipo->offset [all...] |
verify-state.h | 58 struct io_u; 64 extern int verify_state_should_stop(struct thread_data *, struct io_u *);
|
stat.h | 305 extern void add_iops_sample(struct thread_data *, struct io_u *, 307 extern void add_bw_sample(struct thread_data *, struct io_u *, 333 uint32_t *io_u_block_info(struct thread_data *td, struct io_u *io_u);
|
fio.h | 43 #include "io_u.h" 237 * IO engine hooks, contains everything needed to submit an io_u 250 * Queue depth of io_u's that fio MIGHT do 255 * io_u's about to be committed 260 * io_u's submitted but not completed yet 265 * List of free and busy io_u's 502 static inline void fio_ro_check(const struct thread_data *td, struct io_u *io_u) 504 assert(!(io_u->ddir == DDIR_WRITE && !td_write(td))); 651 extern int io_queue_event(struct thread_data *td, struct io_u *io_u, int *ret [all...] |
stat.c | [all...] |
Makefile | 42 eta.c verify.c memory.c io_u.c parse.c mutex.c options.c \
|
options.c | 28 .len = FIELD_SIZE(struct io_u *, offset), [all...] |
/external/fio/engines/ |
null.c | 21 struct io_u **io_us; 26 static struct io_u *fio_null_event(struct thread_data *td, int event) 63 static int fio_null_queue(struct thread_data *td, struct io_u *io_u) 67 fio_ro_check(td, io_u); 74 nd->io_us[nd->queued++] = io_u; 101 nd->io_us = (struct io_u **) malloc(td->o.iodepth * sizeof(struct io_u *)); 102 memset(nd->io_us, 0, td->o.iodepth * sizeof(struct io_u *));
|
binject.c | 24 struct io_u **events; 35 static void binject_buc_init(struct binject_data *bd, struct io_u *io_u) 37 struct b_user_cmd *buc = &io_u->buc; 42 buc->buf = (unsigned long) io_u->xfer_buf; 43 buc->len = io_u->xfer_buflen; 44 buc->offset = io_u->offset; 45 buc->usr_ptr = (unsigned long) io_u; 150 bd->events[ev_index] = (struct io_u *) (unsigned long) buc->usr_ptr; 173 static int fio_binject_doio(struct thread_data *td, struct io_u *io_u [all...] |
libhdfs.c | 123 static int fio_hdfsio_prep(struct thread_data *td, struct io_u *io_u) 132 f_id = floor(io_u->offset / options-> chunck_size); 147 if (io_u->ddir == DDIR_READ || io_u->ddir == DDIR_SYNC) { 149 } else if (io_u->ddir == DDIR_WRITE) { 156 get_chunck_name(fname, io_u->file->file_name, f_id); 168 static int fio_hdfsio_queue(struct thread_data *td, struct io_u *io_u) 175 offset = io_u->offset % options->chunck_size [all...] |
net.c | 332 static int fio_netio_prep(struct thread_data *td, struct io_u *io_u) 342 if ((o->listen && io_u->ddir == DDIR_WRITE) || 343 (!o->listen && io_u->ddir == DDIR_READ)) { 377 static int splice_in(struct thread_data *td, struct io_u *io_u) 381 return splice_io_u(io_u->file->fd, nd->pipes[1], io_u->xfer_buflen); 387 static int splice_out(struct thread_data *td, struct io_u *io_u, [all...] |
fusion-aw.c | 37 static int queue(struct thread_data *td, struct io_u *io_u) 39 struct fas_data *d = FILE_ENG_DATA(io_u->file); 42 if (io_u->ddir != DDIR_WRITE) { 43 td_vmsg(td, EINVAL, "only writes supported", "io_u->ddir"); 48 if ((size_t) io_u->xfer_buf % d->xfer_buf_align) { 49 td_vmsg(td, EINVAL, "unaligned data buffer", "io_u->xfer_buf"); 54 if (io_u->xfer_buflen % d->xfer_buflen_align) { 55 td_vmsg(td, EINVAL, "unaligned data size", "io_u->xfer_buflen"); 60 if (io_u->xfer_buflen > d->xfer_buflen_max) [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...] |
pmemblk.c | 345 static int fio_pmemblk_queue(struct thread_data *td, struct io_u *io_u) 347 struct fio_file *f = io_u->file; 354 fio_ro_check(td, io_u); 356 switch (io_u->ddir) { 359 off = io_u->offset; 360 len = io_u->xfer_buflen; 362 io_u->error = EINVAL; 370 io_u->error = 0; 371 buf = io_u->xfer_buf [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...] |
gfapi.h | 13 struct io_u **aio_events;
|
cpu.c | 56 static int fio_cpuio_queue(struct thread_data *td, struct io_u fio_unused *io_u)
|