Lines Matching refs:td
63 static int fio_posixaio_cancel(struct thread_data fio_unused *td,
75 static int fio_posixaio_prep(struct thread_data fio_unused *td,
93 static int fio_posixaio_getevents(struct thread_data *td, unsigned int min,
96 struct posixaio_data *pd = td->io_ops_data;
114 io_u_qiter(&td->io_u_all, io_u, i) {
162 static struct io_u *fio_posixaio_event(struct thread_data *td, int event)
164 struct posixaio_data *pd = td->io_ops_data;
169 static int fio_posixaio_queue(struct thread_data *td,
172 struct posixaio_data *pd = td->io_ops_data;
176 fio_ro_check(td, io_u);
186 do_io_u_trim(td, io_u);
195 do_io_u_sync(td, io_u);
213 td_verror(td, io_u->error, "xfer");
221 static void fio_posixaio_cleanup(struct thread_data *td)
223 struct posixaio_data *pd = td->io_ops_data;
231 static int fio_posixaio_init(struct thread_data *td)
236 pd->aio_events = malloc(td->o.iodepth * sizeof(struct io_u *));
237 memset(pd->aio_events, 0, td->o.iodepth * sizeof(struct io_u *));
239 td->io_ops_data = pd;
