libaio engine: print warning for depth > 1 and buffered IO

[fio.git] / engines / libaio.c

diff --git a/engines/libaio.c b/engines/libaio.c
index 895b914cf7e044c2bd8ba828035cc3aa8700e391..f8990c1601ba801309d69e7ef84ceb7bfbfcd71c 100644 (file)
--- a/engines/libaio.c
+++ b/engines/libaio.c
@@ -11,7 +11,6 @@
 #include <assert.h>
 
 #include "../fio.h"
 #include <assert.h>
 
 #include "../fio.h"

-#include "../os.h"

 
 #ifdef FIO_HAVE_LIBAIO
 
 
 #ifdef FIO_HAVE_LIBAIO
 


@@ -190,10 +189,19 @@ static void fio_libaio_cleanup(struct thread_data *td)
 static int fio_libaio_init(struct thread_data *td)
 {
        struct libaio_data *ld = malloc(sizeof(*ld));
 static int fio_libaio_init(struct thread_data *td)
 {
        struct libaio_data *ld = malloc(sizeof(*ld));

+       static int warn_print;
+       int err;
+
+       if (td->o.iodepth > 1 && !td->o.odirect && !warn_print) {
+               log_info("fio: libaio engine is only async for non-buffered IO\n");
+               warn_print = 1;
+       }

 
        memset(ld, 0, sizeof(*ld));
 
        memset(ld, 0, sizeof(*ld));

-       if (io_queue_init(td->o.iodepth, &ld->aio_ctx)) {
-               td_verror(td, errno, "io_queue_init");
+
+       err = io_queue_init(td->o.iodepth, &ld->aio_ctx);
+       if (err) {
+               td_verror(td, -err, "io_queue_init");

                free(ld);
                return 1;
        }
                free(ld);
                return 1;
        }