X-Git-Url: https://git.kernel.dk/?p=fio.git;a=blobdiff_plain;f=io_u.c;h=64399797b9b97a03d3bb4375a75a09d43126a46b;hp=132d8970b36d811cace110d7a927820e4b3a5542;hb=36167d82e5f49dee91c6d2cd426068edee90e36f;hpb=48097d5c61aa1718e6dd4b3b647ea2eb6f00fcfb diff --git a/io_u.c b/io_u.c index 132d8970..64399797 100644 --- a/io_u.c +++ b/io_u.c @@ -353,23 +353,23 @@ struct io_u *get_io_u(struct thread_data *td, struct fio_file *f) return NULL; } - f->last_pos += io_u->buflen; + f->last_pos = io_u->offset + io_u->buflen; if (td->verify != VERIFY_NONE) populate_verify_io_u(td, io_u); } - if (td_io_prep(td, io_u)) { - put_io_u(td, io_u); - return NULL; - } - /* * Set io data pointers. */ io_u->xfer_buf = io_u->buf; io_u->xfer_buflen = io_u->buflen; + if (td_io_prep(td, io_u)) { + put_io_u(td, io_u); + return NULL; + } + fio_gettime(&io_u->start_time, NULL); return io_u; } @@ -411,15 +411,20 @@ void io_completed(struct thread_data *td, struct io_u *io_u, icd->error = io_u->error; } -void ios_completed(struct thread_data *td, struct io_completion_data *icd) +void init_icd(struct io_completion_data *icd) { - struct io_u *io_u; - int i; - fio_gettime(&icd->time, NULL); icd->error = 0; icd->bytes_done[0] = icd->bytes_done[1] = 0; +} + +void ios_completed(struct thread_data *td, struct io_completion_data *icd) +{ + struct io_u *io_u; + int i; + + init_icd(icd); for (i = 0; i < icd->nr; i++) { io_u = td->io_ops->event(td, i);