X-Git-Url: https://git.kernel.dk/?p=fio.git;a=blobdiff_plain;f=ioengines.c;h=76e71b9ee4ef1e6cf3c2c23ebc8d036c8d98b04e;hp=34ae91671a4348c43bacdf9f7eddc2f5e81f020d;hb=429f6675446eec26652b010b0c715d8bb6bc32e1;hpb=661598287ecc3b8987f312cf8403936552ce686a diff --git a/ioengines.c b/ioengines.c index 34ae9167..76e71b9e 100644 --- a/ioengines.c +++ b/ioengines.c @@ -192,6 +192,7 @@ int td_io_queue(struct thread_data *td, struct io_u *io_u) if (td->io_ops->flags & FIO_SYNCIO) { fio_gettime(&io_u->issue_time, NULL); + memcpy(&td->last_issue, &io_u->issue_time, sizeof(struct timeval)); /* * for a sync engine, set the timeout upfront @@ -207,9 +208,6 @@ int td_io_queue(struct thread_data *td, struct io_u *io_u) ret = td->io_ops->queue(td, io_u); - if (ret == FIO_Q_QUEUED || ret == FIO_Q_COMPLETED) - get_file(io_u->file); - if (ret == FIO_Q_QUEUED) { int r; @@ -223,6 +221,7 @@ int td_io_queue(struct thread_data *td, struct io_u *io_u) if ((td->io_ops->flags & FIO_SYNCIO) == 0) { fio_gettime(&io_u->issue_time, NULL); + memcpy(&td->last_issue, &io_u->issue_time, sizeof(struct timeval)); /* * async engine, set the timeout here @@ -310,6 +309,7 @@ int td_io_open_file(struct thread_data *td, struct fio_file *f) memset(f->file_map, 0, f->num_maps * sizeof(long)); done: + log_file(td, f, FIO_LOG_OPEN_FILE); td->nr_open_files++; get_file(f); return 0; @@ -321,6 +321,9 @@ err: void td_io_close_file(struct thread_data *td, struct fio_file *f) { + if (!(f->flags & FIO_FILE_CLOSING)) + log_file(td, f, FIO_LOG_CLOSE_FILE); + /* * mark as closing, do real close when last io on it has completed */