10 	struct io_u *io_u;  member
14 static struct io_u *fio_gf_event(struct thread_data *td, int event)  in fio_gf_event()
27 	struct io_u *io_u;  in fio_gf_getevents()  local
32 		io_u_qiter(&td->io_u_all, io_u, i) {  in fio_gf_getevents()
35 			if (!(io_u->flags & IO_U_F_FLIGHT))  in fio_gf_getevents()
38 			io = io_u->engine_data;  in fio_gf_getevents()
41 				g->aio_events[events] = io_u;  in fio_gf_getevents()
59 static void fio_gf_io_u_free(struct thread_data *td, struct io_u *io_u)  in fio_gf_io_u_free()  argument
61 	struct fio_gf_iou *io = io_u->engine_data;  in fio_gf_io_u_free()
66 		io_u->engine_data = NULL;  in fio_gf_io_u_free()
71 static int fio_gf_io_u_init(struct thread_data *td, struct io_u *io_u)  in fio_gf_io_u_init()  argument
75 	if (!io_u->engine_data) {  in fio_gf_io_u_init()
84 		io->io_u = io_u;  in fio_gf_io_u_init()
85 		io_u->engine_data = io;  in fio_gf_io_u_init()
92 	struct io_u *io_u = data;  in gf_async_cb()  local
93 	struct fio_gf_iou *iou = io_u->engine_data;  in gf_async_cb()
100 			      struct io_u *io_u)  in fio_gf_async_queue()  argument
105 	dprint(FD_IO, "%s op %s\n", __FUNCTION__, io_ddir_name(io_u->ddir));  in fio_gf_async_queue()
107 	fio_ro_check(td, io_u);  in fio_gf_async_queue()
109 	if (io_u->ddir == DDIR_READ)  in fio_gf_async_queue()
110 		r = glfs_pread_async(g->fd, io_u->xfer_buf, io_u->xfer_buflen,  in fio_gf_async_queue()
111 				     io_u->offset, 0, gf_async_cb, io_u);  in fio_gf_async_queue()
112 	else if (io_u->ddir == DDIR_WRITE)  in fio_gf_async_queue()
113 		r = glfs_pwrite_async(g->fd, io_u->xfer_buf, io_u->xfer_buflen,  in fio_gf_async_queue()
114 				      io_u->offset, 0, gf_async_cb, io_u);  in fio_gf_async_queue()
116 	else if (io_u->ddir == DDIR_TRIM)  in fio_gf_async_queue()
117 		r = glfs_discard_async(g->fd, io_u->offset, io_u->xfer_buflen,  in fio_gf_async_queue()
118 				       gf_async_cb, io_u);  in fio_gf_async_queue()
120 	else if (io_u->ddir == DDIR_DATASYNC)  in fio_gf_async_queue()
121 		r = glfs_fdatasync_async(g->fd, gf_async_cb, io_u);  in fio_gf_async_queue()
122 	else if (io_u->ddir == DDIR_SYNC)  in fio_gf_async_queue()
123 		r = glfs_fsync_async(g->fd, gf_async_cb, io_u);  in fio_gf_async_queue()
129 		io_u->error = r;  in fio_gf_async_queue()
135 	io_u->error = r;  in fio_gf_async_queue()
136 	td_verror(td, io_u->error, "xfer");  in fio_gf_async_queue()
154 	g->aio_events = calloc(td->o.iodepth, sizeof(struct io_u *));  in fio_gf_async_setup()