From ff52073504552183d8593a39aa4b87d4741b3776 Mon Sep 17 00:00:00 2001 From: Jens Axboe Date: Fri, 11 Jan 2019 10:36:28 -0700 Subject: Sync with kernel API Signed-off-by: Jens Axboe --- src/io_uring.h | 33 +++++++++++++++++++++++++-------- test/io_uring-cp.c | 6 +++--- 2 files changed, 28 insertions(+), 11 deletions(-) diff --git a/src/io_uring.h b/src/io_uring.h index 613930d..74370ae 100644 --- a/src/io_uring.h +++ b/src/io_uring.h @@ -16,7 +16,7 @@ */ struct io_uring_sqe { __u8 opcode; /* type of operation for this sqe */ - __u8 flags; /* as of now unused */ + __u8 flags; /* IOSQE_ flags */ __u16 ioprio; /* ioprio for the request */ __s32 fd; /* file descriptor to do IO on */ __u64 off; /* offset into file */ @@ -27,17 +27,18 @@ struct io_uring_sqe { __u32 len; /* buffer size or number of iovecs */ union { __kernel_rwf_t rw_flags; - __u32 __resv; + __u32 fsync_flags; }; __u16 buf_index; /* index into fixed buffers, if used */ - __u16 __pad2[3]; - __u64 data; /* data to be passed back at completion time */ + __u16 __pad2; + __u32 __pad3; + __u64 user_data; /* data to be passed back at completion time */ }; /* * sqe->flags */ -#define IOSQE_FIXED_BUFFER (1 << 0) /* use fixed buffer */ +#define IOSQE_FIXED_FILE (1 << 0) /* use fixed fileset */ /* * io_uring_setup() flags @@ -49,13 +50,19 @@ struct io_uring_sqe { #define IORING_OP_READV 1 #define IORING_OP_WRITEV 2 #define IORING_OP_FSYNC 3 -#define IORING_OP_FDSYNC 4 +#define IORING_OP_READ_FIXED 4 +#define IORING_OP_WRITE_FIXED 5 + +/* + * sqe->fsync_flags + */ +#define IORING_FSYNC_DATASYNC (1 << 0) /* * IO completion data structure (Completion Queue Entry) */ struct io_uring_cqe { - __u64 data; /* sqe->data submission passed back */ + __u64 user_data; /* sqe->data submission passed back */ __s32 res; /* result code for this event */ __u32 flags; }; @@ -86,6 +93,9 @@ struct io_sqring_offsets { __u32 resv[3]; }; +/* + * sq_ring->flags + */ #define IORING_SQ_NEED_WAKEUP (1 << 0) /* needs io_uring_enter wakeup */ struct io_cqring_offsets { @@ -121,10 +131,17 @@ struct io_uring_params { */ #define IORING_REGISTER_BUFFERS 0 #define IORING_UNREGISTER_BUFFERS 1 +#define IORING_REGISTER_FILES 2 +#define IORING_UNREGISTER_FILES 3 struct io_uring_register_buffers { struct iovec *iovecs; - unsigned nr_iovecs; + __u32 nr_iovecs; +}; + +struct io_uring_register_files { + __s32 *fds; + __u32 nr_fds; }; #endif diff --git a/test/io_uring-cp.c b/test/io_uring-cp.c index a588cc2..ce624c5 100644 --- a/test/io_uring-cp.c +++ b/test/io_uring-cp.c @@ -75,7 +75,7 @@ static int queue_read(int fd, off_t size, off_t offset) sqe->off = offset; sqe->addr = data->iov; sqe->buf_index = 0; - sqe->data = (unsigned long) data; + sqe->user_data = (unsigned long) data; iovecs[sqe_index(sqe)].iov_len = size; sqe->len = 1; return 0; @@ -114,7 +114,7 @@ static int complete_writes(unsigned *writes) static void queue_write(int fd, struct io_uring_cqe *cqe) { - struct io_data *data = (struct io_data *) cqe->data; + struct io_data *data = (struct io_data *) cqe->user_data; struct io_uring_sqe *sqe; sqe = io_uring_get_sqe(&out_ring); @@ -125,7 +125,7 @@ static void queue_write(int fd, struct io_uring_cqe *cqe) sqe->off = data->offset; sqe->addr = data->iov; sqe->buf_index = 0; - sqe->data = 0; + sqe->user_data = 0; data->iov->iov_len = cqe->res; sqe->len = 1; free(data); -- cgit