Move the iodepth_batch into td_io_queue() instead
authorJens Axboe <jens.axboe@oracle.com>
Mon, 26 Feb 2007 13:45:12 +0000 (14:45 +0100)
committerJens Axboe <jens.axboe@oracle.com>
Mon, 26 Feb 2007 13:45:12 +0000 (14:45 +0100)
The previous part in do_io() introduced a bug (overwriting ret),
and we really need to do it from other locations as well.

Signed-off-by: Jens Axboe <jens.axboe@oracle.com>
fio.c
ioengines.c

diff --git a/fio.c b/fio.c
index c5b85ae..b095527 100644 (file)
--- a/fio.c
+++ b/fio.c
@@ -433,8 +433,6 @@ 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);
index 2cc3288..14b15cc 100644 (file)
@@ -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);