X-Git-Url: https://git.kernel.dk/?a=blobdiff_plain;f=engines%2Flibaio.c;h=e452f1ca7c55f630c18c49186ece3f091713d0db;hb=1621031e8a7cbb91afad124da405fc4eabda764f;hp=18dcf9ddfad59d753a2cf4b71061065dc6baf6fc;hpb=12d9d841526ad75a67bb43a90edeefd05f85f11e;p=fio.git diff --git a/engines/libaio.c b/engines/libaio.c index 18dcf9dd..e452f1ca 100644 --- a/engines/libaio.c +++ b/engines/libaio.c @@ -64,11 +64,11 @@ static int fio_libaio_getevents(struct thread_data *td, unsigned int min, unsigned int max, struct timespec *t) { struct libaio_data *ld = td->io_ops->data; - long r; + int r; do { r = io_getevents(ld->aio_ctx, min, max, ld->aio_events, t); - if (r >= min) + if (r >= (int) min) break; else if (r == -EAGAIN) { usleep(100); @@ -186,14 +186,8 @@ 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 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)); err = io_queue_init(td->o.iodepth, &ld->aio_ctx); @@ -229,6 +223,7 @@ static struct ioengine_ops ioengine = { .cleanup = fio_libaio_cleanup, .open_file = generic_open_file, .close_file = generic_close_file, + .get_file_size = generic_get_file_size, }; #else /* FIO_HAVE_LIBAIO */