Recent changes (master)

[Jens Axboe <axboe@kernel.dk>]

The following changes since commit ae35a58399b28edf857f7ebc43b3eb40d86ac29b:

  Merge branch 'verify-zero-dump' of https://github.com/sarthak-k/fio (2026-08-26 16:12:53 +0000)

are available in the Git repository at:

  git://git.kernel.dk/fio.git master

for you to fetch changes up to 975ea1856fee9f4c0f01f6f19ba3c61ce24f9bc8:

  Merge branch 'consolidate_commit_call_path' of https://github.com/dennischerchang/fio (2026-09-01 21:48:38 +0000)

----------------------------------------------------------------
Dennis Chang (1):
      Consolidate all caller of io_ops_commit() to call td_io_commit().

Vincent Fu (1):
      Merge branch 'consolidate_commit_call_path' of https://github.com/dennischerchang/fio

 ioengines.c | 13 ++++++++-----
 ioengines.h |  2 +-
 2 files changed, 9 insertions(+), 6 deletions(-)

---

Diff of recent changes:

diff --git a/ioengines.c b/ioengines.c
index 911a286e..b0b18d34 100644
--- a/ioengines.c
+++ b/ioengines.c
@@ -304,8 +304,7 @@ int td_io_getevents(struct thread_data *td, unsigned int min, unsigned int max,
 		return 0;
 
 	if (min > 0 && td->io_ops->commit) {
-		r = td->io_ops->commit(td);
-		if (r < 0)
+		if (!td_io_commit(td))
 			goto out;
 	}
 	if (max > td->cur_depth)
@@ -502,21 +501,24 @@ int td_io_init(struct thread_data *td)
 	return ret;
 }
 
-void td_io_commit(struct thread_data *td)
+bool td_io_commit(struct thread_data *td)
 {
 	int ret;
+	bool commit_success = true;
 
 	dprint(FD_IO, "calling ->commit(), depth %d\n", td->cur_depth);
 
 	if (!td->cur_depth || !td->io_u_queued)
-		return;
+		return true;
 
 	io_u_mark_depth(td, td->io_u_queued);
 
 	if (td->io_ops->commit) {
 		ret = td->io_ops->commit(td);
-		if (ret)
+		if (ret) {
 			td_verror(td, -ret, "io commit");
+			commit_success = false;
+		}
 	}
 
 	/*
@@ -524,6 +526,7 @@ void td_io_commit(struct thread_data *td)
 	 */
 	td->io_u_in_flight += td->io_u_queued;
 	td->io_u_queued = 0;
+	return commit_success;
 }
 
 int td_io_open_file(struct thread_data *td, struct fio_file *f)
diff --git a/ioengines.h b/ioengines.h
index b0a767ba..d58b95c7 100644
--- a/ioengines.h
+++ b/ioengines.h
@@ -141,7 +141,7 @@ extern int __must_check td_io_init(struct thread_data *);
 extern int __must_check td_io_prep(struct thread_data *, struct io_u *);
 extern enum fio_q_status __must_check td_io_queue(struct thread_data *, struct io_u *);
 extern int __must_check td_io_getevents(struct thread_data *, unsigned int, unsigned int, const struct timespec *);
-extern void td_io_commit(struct thread_data *);
+extern bool td_io_commit(struct thread_data *);
 extern int __must_check td_io_open_file(struct thread_data *, struct fio_file *);
 extern int td_io_close_file(struct thread_data *, struct fio_file *);
 extern int td_io_unlink_file(struct thread_data *, struct fio_file *);