[PATCH] One more round of random map fixes

[fio.git] / engines / libaio.c

diff --git a/engines/libaio.c b/engines/libaio.c
index acc125f48e46df799c7d7fdcf0c42daea9694145..c2f47d8bc87aee1b2b76d117c1f8d7c2532ea35a 100644 (file)
--- a/engines/libaio.c
+++ b/engines/libaio.c
@@ -88,7 +88,7 @@ static int fio_libaio_queue(struct thread_data *td, struct io_u *io_u)
        do {
                ret = io_submit(ld->aio_ctx, 1, &iocb);
                if (ret == 1)
-                       return 0;
+                       break;
                else if (ret == -EAGAIN || !ret)
                        usleep(100);
                else if (ret == -EINTR)
@@ -101,8 +101,12 @@ static int fio_libaio_queue(struct thread_data *td, struct io_u *io_u)
                         * with libaio (still), we don't have pending
                         * requests to flush first.
                         */
-                       ret = fsync(io_u->file->fd);
-                       ld->sync_io_u = io_u;
+                       if (fsync(io_u->file->fd) < 0)
+                               ret = errno;
+                       else {
+                               ret = 1;
+                               ld->sync_io_u = io_u;
+                       }
                        break;
                } else
                        break;
@@ -111,6 +115,7 @@ static int fio_libaio_queue(struct thread_data *td, struct io_u *io_u)
        if (ret <= 0) {
                io_u->resid = io_u->xfer_buflen;
                io_u->error = -ret;
+               td_verror(td, io_u->error);
                return 1;
        }