From: Jens Axboe <axboe@kernel.dk>
Date: Sat, 1 Dec 2018 17:17:26 +0000 (-0700)
Subject: engines/libaio: set IOCB_HIPRI if we are polling
X-Git-Tag: fio-3.13~91
X-Git-Url: https://git.kernel.dk/?a=commitdiff_plain;h=6f3a2c116481731abdf2fbed2d0f63cf4d3ddca2;p=fio.git

engines/libaio: set IOCB_HIPRI if we are polling

Forgot to set it for the non-user mapped case.

Signed-off-by: Jens Axboe <axboe@kernel.dk>
---

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);