Add iodepth_batch setting

[fio.git] / fio.c

diff --git a/fio.c b/fio.c
index b095527e4d028d18ab30d185a7b25c4a93eba7ab..c5b85aeb8c88ca2ef732135fc74ffb8d789325c1 100644 (file)
--- a/fio.c
+++ b/fio.c
@@ -433,6 +433,8 @@ requeue:
                         */
                        if (td->io_ops->commit == NULL)
                                io_u_queued(td, io_u);
+                       else if (td->io_u_queued >= td->iodepth_batch)
+                               ret = td_io_commit(td);
                        break;
                case FIO_Q_BUSY:
                        requeue_io_u(td, &io_u);