Skip to contentSkip to conversation

Recent changes (master)

PATCH Jens Axboe 1 participant 1 message Dec 2, 2018

lore
Share & tools
lore

Jens Axboe

author
#0 lore raw

The following changes since commit 68afa5b570a7e0dce0470817037f7828cf36cd2f:

stat: assign for first stat iteration, don't sum (2018-11-30 14:44:25 -0700)

are available in the git repository at:

git://git.kernel.dk/fio.git master

for you to fetch changes up to 6f3a2c116481731abdf2fbed2d0f63cf4d3ddca2:

engines/libaio: set IOCB_HIPRI if we are polling (2018-12-01 10:17:26 -0700)

----------------------------------------------------------------
Jens Axboe (1):
engines/libaio: set IOCB_HIPRI if we are polling

 engines/libaio.c | 10 ++++++++--
 1 file changed, 8 insertions(+), 2 deletions(-)

---

Diff of recent changes:

engines/libaio.c +8 -2
index 9c8a61b..a780b2b 100644
@@ -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);