Lines Matching refs:td
57 static int fio_syncio_prep(struct thread_data *td, struct io_u *io_u)
68 td_verror(td, errno, "lseek");
75 static int fio_io_end(struct thread_data *td, struct io_u *io_u, int ret)
90 io_u_log_error(td, io_u);
91 td_verror(td, io_u->error, "xfer");
98 static int fio_pvsyncio_queue(struct thread_data *td, struct io_u *io_u)
100 struct syncio_data *sd = td->io_ops_data;
105 fio_ro_check(td, io_u);
115 do_io_u_trim(td, io_u);
118 ret = do_io_u_sync(td, io_u);
120 return fio_io_end(td, io_u, ret);
125 static int fio_pvsyncio2_queue(struct thread_data *td, struct io_u *io_u)
127 struct syncio_data *sd = td->io_ops_data;
128 struct psyncv2_options *o = td->eo;
133 fio_ro_check(td, io_u);
146 do_io_u_trim(td, io_u);
149 ret = do_io_u_sync(td, io_u);
151 return fio_io_end(td, io_u, ret);
156 static int fio_psyncio_queue(struct thread_data *td, struct io_u *io_u)
161 fio_ro_check(td, io_u);
168 do_io_u_trim(td, io_u);
171 ret = do_io_u_sync(td, io_u);
173 return fio_io_end(td, io_u, ret);
176 static int fio_syncio_queue(struct thread_data *td, struct io_u *io_u)
181 fio_ro_check(td, io_u);
188 do_io_u_trim(td, io_u);
191 ret = do_io_u_sync(td, io_u);
193 return fio_io_end(td, io_u, ret);
196 static int fio_vsyncio_getevents(struct thread_data *td, unsigned int min,
200 struct syncio_data *sd = td->io_ops_data;
213 static struct io_u *fio_vsyncio_event(struct thread_data *td, int event)
215 struct syncio_data *sd = td->io_ops_data;
220 static int fio_vsyncio_append(struct thread_data *td, struct io_u *io_u)
222 struct syncio_data *sd = td->io_ops_data;
247 static int fio_vsyncio_queue(struct thread_data *td, struct io_u *io_u)
249 struct syncio_data *sd = td->io_ops_data;
251 fio_ro_check(td, io_u);
253 if (!fio_vsyncio_append(td, io_u)) {
262 int ret = do_io_u_sync(td, io_u);
264 return fio_io_end(td, io_u, ret);
271 if (sd->queued == td->o.iodepth) {
287 static int fio_vsyncio_end(struct thread_data *td, ssize_t bytes)
289 struct syncio_data *sd = td->io_ops_data;
320 td_verror(td, err, "xfer vsync");
327 static int fio_vsyncio_commit(struct thread_data *td)
329 struct syncio_data *sd = td->io_ops_data;
336 io_u_mark_submit(td, sd->queued);
342 td_verror(td, errno, "lseek");
354 return fio_vsyncio_end(td, ret);
357 static int fio_vsyncio_init(struct thread_data *td)
364 sd->iovecs = malloc(td->o.iodepth * sizeof(struct iovec));
365 sd->io_us = malloc(td->o.iodepth * sizeof(struct io_u *));
367 td->io_ops_data = sd;
371 static void fio_vsyncio_cleanup(struct thread_data *td)
373 struct syncio_data *sd = td->io_ops_data;
