16 	struct io_u **aio_events;
64 			       struct io_u *io_u)  in fio_posixaio_cancel()  argument
66 	struct fio_file *f = io_u->file;  in fio_posixaio_cancel()
67 	int r = aio_cancel(f->fd, &io_u->aiocb);  in fio_posixaio_cancel()
76 			     struct io_u *io_u)  in fio_posixaio_prep()  argument
78 	os_aiocb_t *aiocb = &io_u->aiocb;  in fio_posixaio_prep()
79 	struct fio_file *f = io_u->file;  in fio_posixaio_prep()
82 	aiocb->aio_buf = io_u->xfer_buf;  in fio_posixaio_prep()
83 	aiocb->aio_nbytes = io_u->xfer_buflen;  in fio_posixaio_prep()
84 	aiocb->aio_offset = io_u->offset;  in fio_posixaio_prep()
87 	io_u->seen = 0;  in fio_posixaio_prep()
101 	struct io_u *io_u;  in fio_posixaio_getevents()  local
114 	io_u_qiter(&td->io_u_all, io_u, i) {  in fio_posixaio_getevents()
117 		if (io_u->seen || !(io_u->flags & IO_U_F_FLIGHT))  in fio_posixaio_getevents()
120 		err = aio_error(&io_u->aiocb);  in fio_posixaio_getevents()
123 				suspend_list[suspend_entries] = &io_u->aiocb;  in fio_posixaio_getevents()
129 		io_u->seen = 1;  in fio_posixaio_getevents()
131 		pd->aio_events[r++] = io_u;  in fio_posixaio_getevents()
134 			io_u->resid = io_u->xfer_buflen;  in fio_posixaio_getevents()
136 			ssize_t retval = aio_return(&io_u->aiocb);  in fio_posixaio_getevents()
138 			io_u->resid = io_u->xfer_buflen - retval;  in fio_posixaio_getevents()
140 			io_u->error = err;  in fio_posixaio_getevents()
162 static struct io_u *fio_posixaio_event(struct thread_data *td, int event)  in fio_posixaio_event()
170 			      struct io_u *io_u)  in fio_posixaio_queue()  argument
173 	os_aiocb_t *aiocb = &io_u->aiocb;  in fio_posixaio_queue()
176 	fio_ro_check(td, io_u);  in fio_posixaio_queue()
178 	if (io_u->ddir == DDIR_READ)  in fio_posixaio_queue()
180 	else if (io_u->ddir == DDIR_WRITE)  in fio_posixaio_queue()
182 	else if (io_u->ddir == DDIR_TRIM) {  in fio_posixaio_queue()
186 		do_io_u_trim(td, io_u);  in fio_posixaio_queue()
195 		do_io_u_sync(td, io_u);  in fio_posixaio_queue()
212 		io_u->error = aio_err;  in fio_posixaio_queue()
213 		td_verror(td, io_u->error, "xfer");  in fio_posixaio_queue()
236 	pd->aio_events = malloc(td->o.iodepth * sizeof(struct io_u *));  in fio_posixaio_init()
237 	memset(pd->aio_events, 0, td->o.iodepth * sizeof(struct io_u *));  in fio_posixaio_init()