Searched defs:io_u (Results 1 - 25 of 29) sorted by relevance

12

/external/fio/
H A Dtrim.c14 int get_next_trim(struct thread_data *td, struct io_u *io_u) argument
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
70 io_u_should_trim(struct thread_data *td, struct io_u *io_u) argument
[all...]
H A Dtrim.h7 extern int __must_check get_next_trim(struct thread_data *td, struct io_u *io_u);
8 extern int 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 int get_next_trim(struct thread_data *td, struct io_u *io_u) argument
27 static inline int io_u_should_trim(struct thread_data *td, struct io_u *io_u) argument
H A Dio_u_queue.h6 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) argument
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_ argument
61 struct io_u *io_u = r->ring[r->tail]; local
[all...]
H A Dioengines.c203 int td_io_prep(struct thread_data *td, struct io_u *io_u) argument
205 dprint_io_u(io_u, "prep");
206 fio_ro_check(td, io_u);
208 lock_file(td, io_u->file, io_u->ddir);
211 int ret = td->io_ops->prep(td, io_u);
213 dprint(FD_IO, "->prep(%p)=%d\n", io_u, ret);
215 unlock_file(td, io_u->file);
265 int td_io_queue(struct thread_data *td, struct io_u *io_ argument
530 do_io_u_sync(struct thread_data *td, struct io_u *io_u) argument
556 do_io_u_trim(struct thread_data *td, struct io_u *io_u) argument
[all...]
H A Dioengine.h34 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 *);
220 dprint_io_u(struct io_u *io_u, const char *p) argument
238 acct_ddir(struct io_u *io_u) argument
[all...]
H A Diolog.c23 void log_io_u(struct thread_data *td, struct io_u *io_u) argument
28 assert(io_u->ddir <= 6);
33 fprintf(td->iolog_f, "%s %s %llu %lu\n", io_u->file->file_name,
34 act[io_u->ddir], io_u->offset,
35 io_u->buflen);
118 int read_iolog_get(struct thread_data *td, struct io_u *io_u) argument
139 io_u
190 log_io_piece(struct thread_data *td, struct io_u *io_u) argument
271 unlog_io_piece(struct thread_data *td, struct io_u *io_u) argument
288 trim_io_piece(struct thread_data *td, struct io_u *io_u) argument
[all...]
H A Dverify.c28 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) argument
95 hdr_inc = io_u
67 fill_verify_pattern(struct thread_data *td, void *p, unsigned int len, struct io_u *io_u, unsigned long seed, int use_seed) argument
102 fill_pattern_headers(struct thread_data *td, struct io_u *io_u, unsigned long seed, int use_seed) argument
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
659 verify_io_u_async(struct thread_data *td, struct io_u *io_u) argument
678 verify_trimmed_io_u(struct thread_data *td, struct io_u *io_u) argument
712 verify_header(struct io_u *io_u, struct verify_header *hdr) argument
731 verify_io_u(struct thread_data *td, struct io_u *io_u) argument
869 fill_meta(struct verify_header *hdr, struct thread_data *td, struct io_u *io_u, unsigned int header_num) argument
973 populate_hdr(struct thread_data *td, struct io_u *io_u, struct verify_header *hdr, unsigned int header_num, unsigned int header_len) argument
1063 populate_verify_io_u(struct thread_data *td, struct io_u *io_u) argument
1073 get_next_verify(struct thread_data *td, struct io_u *io_u) argument
1169 struct io_u *io_u; local
[all...]
/external/fio/engines/
H A Dcpu.c55 static int fio_cpuio_queue(struct thread_data *td, struct io_u fio_unused *io_u) argument
H A Dfalloc.c73 static int fio_fallocate_queue(struct thread_data *td, struct io_u *io_u) argument
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
[all...]
H A Dskeleton_external.c24 * 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) argument
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
65 fio_skeleton_queue(struct thread_data *td, struct io_u *io_u) argument
86 fio_skeleton_prep(struct thread_data *td, struct io_u *io_u) argument
[all...]
H A Dfusion-aw.c37 static int queue(struct thread_data *td, struct io_u *io_u) argument
40 struct fas_data *d = (struct fas_data *) io_u->file->engine_data;
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
[all...]
H A Dmmap.c69 static int fio_mmapio_prep_limited(struct thread_data *td, struct io_u *io_u) argument
71 struct fio_file *f = io_u->file;
73 if (io_u->buflen > mmap_map_size) {
82 f->mmap_off = io_u->offset;
90 static int fio_mmapio_prep_full(struct thread_data *td, struct io_u *io_u) argument
92 struct fio_file *f = io_u->file;
108 static int fio_mmapio_prep(struct thread_data *td, struct io_u *io_u) argument
142 fio_mmapio_queue(struct thread_data *td, struct io_u *io_u) argument
[all...]
H A Dnull.c21 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) argument
67 fio_ro_check(td, io_u);
74 nd->io_us[nd->queued++] = io_u;
102 nd->io_us = (struct io_u **) malloc(td->o.iodepth * sizeof(struct io_u *));
103 memset(nd->io_us, 0, td->o.iodepth * sizeof(struct io_u *));
H A De4defrag.c131 static int fio_e4defrag_queue(struct thread_data *td, struct io_u *io_u) argument
137 struct fio_file *f = io_u->file;
141 fio_ro_check(td, io_u);
147 if (io_u->ddir != DDIR_WRITE) {
148 io_u->error = EINVAL;
153 ret = fallocate(ed->donor_fd, 0, io_u->offset, io_u->xfer_buflen);
160 me.orig_start = io_u->offset / ed->bsz;
162 len = (io_u
[all...]
H A Dguasi.c37 struct io_u **io_us;
42 static int fio_guasi_prep(struct thread_data fio_unused *td, struct io_u *io_u) argument
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
116 fio_guasi_queue(struct thread_data *td, struct io_u *io_u) argument
134 struct io_u *io_u; local
153 struct io_u *io_u; local
189 fio_guasi_cancel(struct thread_data fio_unused *td, struct io_u *io_u) argument
[all...]
H A Dsolarisaio.c16 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
22 fio_solarisaio_cancel(struct thread_data fio_unused *td, struct io_u *io_u) argument
28 fio_solarisaio_prep(struct thread_data fio_unused *td, struct io_u *io_u) argument
108 fio_solarisaio_queue(struct thread_data fio_unused *td, struct io_u *io_u) argument
[all...]
H A Dsplice.c29 static int fio_splice_read_old(struct thread_data *td, struct io_u *io_u) argument
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) argument
76 struct fio_file *f = io_u
167 fio_splice_write(struct thread_data *td, struct io_u *io_u) argument
202 fio_spliceio_queue(struct thread_data *td, struct io_u *io_u) argument
[all...]
H A Dbinject.c24 struct io_u **events;
35 static void binject_buc_init(struct binject_data *bd, struct io_u *io_u) argument
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_ argument
186 fio_binject_prep(struct thread_data *td, struct io_u *io_u) argument
216 fio_binject_queue(struct thread_data *td, struct io_u *io_u) argument
[all...]
H A Dlibaio.c20 struct io_u **io_us;
44 static int fio_libaio_prep(struct thread_data fio_unused *td, struct io_u *io_u) argument
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
62 struct io_u *io_u; local
147 fio_libaio_queue(struct thread_data *td, struct io_u *io_u) argument
196 struct io_u *io_u = io_us[i]; local
235 fio_libaio_cancel(struct thread_data *td, struct io_u *io_u) argument
[all...]
H A Dposixaio.c16 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
63 fio_posixaio_cancel(struct thread_data fio_unused *td, struct io_u *io_u) argument
75 fio_posixaio_prep(struct thread_data fio_unused *td, struct io_u *io_u) argument
101 struct io_u *io_u; local
169 fio_posixaio_queue(struct thread_data *td, struct io_u *io_u) argument
[all...]
H A Drbd.c13 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_ local
208 struct io_u *io_u; local
236 fio_rbd_queue(struct thread_data *td, struct io_u *io_u) argument
405 fio_rbd_io_u_free(struct thread_data *td, struct io_u *io_u) argument
415 fio_rbd_io_u_init(struct thread_data *td, struct io_u *io_u) argument
[all...]
H A Dsg.c25 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)
33 sgio_hdr_init(struct sgio_data *sd, struct sg_io_hdr *hdr, struct io_u *io_u, int fs) argument
159 fio_sgio_ioctl_doio(struct thread_data *td, struct fio_file *f, struct io_u *io_u) argument
175 fio_sgio_rw_doio(struct fio_file *f, struct io_u *io_u, int do_sync) argument
194 fio_sgio_doio(struct thread_data *td, struct io_u *io_u, int do_sync) argument
204 fio_sgio_prep(struct thread_data *td, struct io_u *io_u) argument
246 fio_sgio_queue(struct thread_data *td, struct io_u *io_u) argument
283 struct io_u io_u; local
[all...]
H A Dsync.c24 struct io_u **io_us;
34 static int fio_syncio_prep(struct thread_data *td, struct io_u *io_u) argument
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) argument
54 if (io_u
73 fio_pvsyncio_queue(struct thread_data *td, struct io_u *io_u) argument
99 fio_psyncio_queue(struct thread_data *td, struct io_u *io_u) argument
119 fio_syncio_queue(struct thread_data *td, struct io_u *io_u) argument
163 fio_vsyncio_append(struct thread_data *td, struct io_u *io_u) argument
177 fio_vsyncio_set_iov(struct syncio_data *sd, struct io_u *io_u, int idx) argument
190 fio_vsyncio_queue(struct thread_data *td, struct io_u *io_u) argument
233 struct io_u *io_u; local
[all...]
H A Dwindowsaio.c21 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
308 fio_windowsaio_queue(struct thread_data *td, struct io_u *io_u) argument
367 struct io_u *io_u; local
400 fio_windowsaio_io_u_free(struct thread_data *td, struct io_u *io_u) argument
411 fio_windowsaio_io_u_init(struct thread_data *td, struct io_u *io_u) argument
[all...]
H A Drdma.c109 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) argument
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
512 struct io_u *io_u; local
688 fio_rdmaio_queue(struct thread_data *td, struct io_u *io_u) argument
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...]

Completed in 830 milliseconds

12