From 6f3a2c116481731abdf2fbed2d0f63cf4d3ddca2 Mon Sep 17 00:00:00 2001 From: Jens Axboe Date: Sat, 1 Dec 2018 10:17:26 -0700 Subject: [PATCH] engines/libaio: set IOCB_HIPRI if we are polling Forgot to set it for the non-user mapped case. Signed-off-by: Jens Axboe --- engines/libaio.c | 10 ++++++++-- 1 file changed, 8 insertions(+), 2 deletions(-) diff --git a/engines/libaio.c b/engines/libaio.c index 9c8a61b7..a780b2b8 100644 --- a/engines/libaio.c +++ b/engines/libaio.c @@ -130,15 +130,21 @@ static int fio_libaio_prep(struct thread_data fio_unused *td, struct io_u *io_u) iocb->aio_fildes = f->fd; iocb->aio_lio_opcode = IO_CMD_PREAD; iocb->u.c.offset = io_u->offset; - } else + } else { io_prep_pread(iocb, f->fd, io_u->xfer_buf, io_u->xfer_buflen, io_u->offset); + if (o->hipri) + iocb->u.c.flags |= IOCB_FLAG_HIPRI; + } } else if (io_u->ddir == DDIR_WRITE) { if (o->fixedbufs) { iocb->aio_fildes = f->fd; iocb->aio_lio_opcode = IO_CMD_PWRITE; iocb->u.c.offset = io_u->offset; - } else + } else { io_prep_pwrite(iocb, f->fd, io_u->xfer_buf, io_u->xfer_buflen, io_u->offset); + if (o->hipri) + iocb->u.c.flags |= IOCB_FLAG_HIPRI; + } } else if (ddir_sync(io_u->ddir)) io_prep_fsync(iocb, f->fd); -- 2.25.1