if (io_u->ddir != DDIR_SYNC)
td->io_issues[io_u->ddir]++;
- io_u_mark_depth(td, io_u);
-
ret = td->io_ops->queue(td, io_u);
+ if (ret != FIO_Q_BUSY)
+ io_u_mark_depth(td, io_u);
+
if (ret == FIO_Q_QUEUED) {
int r;
return 1;
}
-void td_io_close_file(struct thread_data *td, struct fio_file *f)
+int 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);
*/
f->flags |= FIO_FILE_CLOSING;
- put_file(td, f);
+ return put_file(td, f);
}