Searched refs:io_us (Results 1 – 7 of 7) sorted by relevance
| /external/fio/engines/ |
| D | libaio.c | 20 struct io_u **io_us; member
179 ld->io_us[ld->iocbs_nr] = io_u; in fio_libaio_queue()
184 static void fio_libaio_queued(struct thread_data *td, struct io_u **io_us, in fio_libaio_queued() argument
196 struct io_u *io_u = io_us[i]; in fio_libaio_queued()
207 struct io_u **io_us; in fio_libaio_commit() local
213 io_us = ld->io_us; in fio_libaio_commit()
218 fio_libaio_queued(td, io_us, ret); in fio_libaio_commit()
221 io_us += ret; in fio_libaio_commit()
250 free(ld->io_us); in fio_libaio_cleanup()
283 ld->io_us = malloc(td->o.iodepth * sizeof(struct io_u *)); in fio_libaio_init()
[all …]
|
| D | null.c | 21 struct io_u **io_us; member
30 return nd->io_us[event]; in fio_null_event()
74 nd->io_us[nd->queued++] = io_u; in fio_null_queue()
89 if (nd->io_us) in fio_null_cleanup()
90 free(nd->io_us); in fio_null_cleanup()
102 nd->io_us = (struct io_u **) malloc(td->o.iodepth * sizeof(struct io_u *)); in fio_null_init()
103 memset(nd->io_us, 0, td->o.iodepth * sizeof(struct io_u *)); in fio_null_init()
|
| D | guasi.c | 37 struct io_u **io_us; member
126 ld->io_us[ld->queued_nr] = io_u; in fio_guasi_queue()
131 static void fio_guasi_queued(struct thread_data *td, struct io_u **io_us, int nr) in fio_guasi_queued() argument
143 io_u = io_us[i]; in fio_guasi_queued()
158 io_u = ld->io_us[i]; in fio_guasi_commit()
182 fio_guasi_queued(td, ld->io_us, i); in fio_guasi_commit()
210 free(ld->io_us); in fio_guasi_cleanup()
233 ld->io_us = malloc(ld->max_reqs * sizeof(struct io_u *)); in fio_guasi_init()
234 memset(ld->io_us, 0, ld->max_reqs * sizeof(struct io_u *)); in fio_guasi_init()
|
| D | rdma.c | 588 static int fio_rdmaio_send(struct thread_data *td, struct io_u **io_us, in fio_rdmaio_send() argument
608 r_io_u_d = io_us[i]->engine_data; in fio_rdmaio_send()
614 r_io_u_d->sq_wr.sg_list->length = io_us[i]->buflen; in fio_rdmaio_send()
618 r_io_u_d = io_us[i]->engine_data; in fio_rdmaio_send()
624 r_io_u_d->sq_wr.sg_list->length = io_us[i]->buflen; in fio_rdmaio_send()
627 r_io_u_d = io_us[i]->engine_data; in fio_rdmaio_send()
642 dprint_io_u(io_us[i], "fio_rdmaio_send"); in fio_rdmaio_send()
651 static int fio_rdmaio_recv(struct thread_data *td, struct io_u **io_us, in fio_rdmaio_recv() argument
663 r_io_u_d = io_us[i]->engine_data; in fio_rdmaio_recv()
705 static void fio_rdmaio_queued(struct thread_data *td, struct io_u **io_us, in fio_rdmaio_queued() argument
[all …]
|
| D | sync.c | 24 struct io_u **io_us; member
160 return sd->io_us[event]; in fio_vsyncio_event()
180 sd->io_us[idx] = io_u; in fio_vsyncio_set_iov()
245 io_u = sd->io_us[i]; in fio_vsyncio_end()
282 if (lseek(f->fd, sd->io_us[0]->offset, SEEK_SET) == -1) { in fio_vsyncio_commit()
308 sd->io_us = malloc(td->o.iodepth * sizeof(struct io_u *)); in fio_vsyncio_init()
319 free(sd->io_us); in fio_vsyncio_cleanup()
|
| /external/fio/ |
| D | io_u_queue.h | 9 struct io_u **io_us; member
16 return q->io_us[--q->nr]; in io_u_qpop()
23 q->io_us[q->nr++] = io_u; in io_u_qpush()
32 for (i = 0; i < (q)->nr && (io_u = (q)->io_us[i]); i++)
|
| D | io_u_queue.c | 6 q->io_us = calloc(nr, sizeof(struct io_u *)); in io_u_qinit()
7 if (!q->io_us) in io_u_qinit()
16 free(q->io_us); in io_u_qexit()
|