X-Git-Url: https://git.kernel.dk/?p=fio.git;a=blobdiff_plain;f=ioengines.c;h=14b15ccd7468e6646a03b962095a97fb55cff74a;hp=2cc328883d806497b4f9028919cefe360ef3a377;hb=eb7c8ae27bc301b77490b3586dd5ccab7c95880a;hpb=ec1aee01a92f2e390d7ca14d26eebf6453780c53;ds=sidebyside

diff --git a/ioengines.c b/ioengines.c
index 2cc32888..14b15ccd 100644
--- a/ioengines.c
+++ b/ioengines.c
@@ -216,8 +216,16 @@ 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)
+	if (ret == FIO_Q_QUEUED) {
+		int r;
+
 		td->io_u_queued++;
+		if (td->io_u_queued > td->iodepth_batch) {
+			r = td_io_commit(td);
+			if (r < 0)
+				return r;
+		}
+	}
 
 	if ((td->io_ops->flags & FIO_SYNCIO) == 0) {
 		fio_gettime(&io_u->issue_time, NULL);