*/
struct io_uring_sqe {
__u8 opcode; /* type of operation for this sqe */
- __u8 flags; /* as of now unused */
+ __u8 flags; /* IOSQE_ flags below */
__u16 ioprio; /* ioprio for the request */
__s32 fd; /* file descriptor to do IO on */
__u64 off; /* offset into file */
* sqe->flags
*/
#define IOSQE_FIXED_BUFFER (1 << 0) /* use fixed buffer */
+#define IOSQE_FIXED_FILE (1 << 1) /* use fixed fileset */
/*
* io_uring_setup() flags
*/
#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;
};
+struct io_uring_register_files {
+ int *fds;
+ unsigned nr_fds;
+};
+
#endif
IORING_REGISTER_BUFFERS, ®);
}
+static int io_uring_register_files(struct submitter *s)
+{
+ struct io_uring_register_files reg;
+ int i, ret;
+
+ reg.fds = calloc(s->nr_files, sizeof(int));
+ for (i = 0; i < s->nr_files; i++)
+ reg.fds[i] = s->files[i].fd;
+ reg.nr_fds = s->nr_files;
+
+ ret = syscall(__NR_sys_io_uring_register, s->ring_fd,
+ IORING_REGISTER_FILES, ®);
+ free(reg.fds);
+ return ret;
+}
+
static int io_uring_setup(unsigned entries, struct io_uring_params *p)
{
return syscall(__NR_sys_io_uring_setup, entries, p);
lrand48_r(&s->rand, &r);
offset = (r % (f->max_blocks - 1)) * BS;
- sqe->flags = 0;
+ sqe->flags = IOSQE_FIXED_FILE;
sqe->opcode = IORING_OP_READV;
if (fixedbufs) {
sqe->addr = s->iovecs[index].iov_base;
if (fixedbufs) {
ret = io_uring_register_buffers(s);
if (ret < 0) {
- perror("io_uring_register");
+ perror("io_uring_register_buffers");
return 1;
}
}
+ ret = io_uring_register_files(s);
+ if (ret < 0) {
+ perror("io_uring_register_files");
+ return 1;
+ }
+
ptr = mmap(0, p.sq_off.array + p.sq_entries * sizeof(__u32),
PROT_READ | PROT_WRITE, MAP_SHARED | MAP_POPULATE, fd,
IORING_OFF_SQ_RING);