cpp/liburing
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Add read/write fixed prep support

Browse Source 
Also unify the setup, all the read/write variants can use the same
helper.

Signed-off-by: Jens Axboe <axboe@kernel.dk>
This commit is contained in:
Jens Axboe
2019-02-28 13:38:41 -07:00
parent 5b5e6fe360
commit 432fa1d3d1
1 changed files with 27 additions and 12 deletions
Download Patch File Download Diff File Expand all files Collapse all files

39
src/liburing.h
View File

@@ -74,28 +74,43 @@ static inline void io_uring_sqe_set_data(struct io_uring_sqe *sqe, void *data)
sqe->user_data = (unsigned long) data; sqe->user_data = (unsigned long) data;
} }
static inline void io_uring_prep_rw(int op, struct io_uring_sqe *sqe, int fd,
void *addr, unsigned len, off_t offset)
{
memset(sqe, 0, sizeof(*sqe));
sqe->opcode = op;
sqe->fd = fd;
sqe->off = offset;
sqe->addr = (unsigned long) addr;
sqe->len = len;
}
static inline void io_uring_prep_readv(struct io_uring_sqe *sqe, int fd, static inline void io_uring_prep_readv(struct io_uring_sqe *sqe, int fd,
struct iovec *iovecs, unsigned nr_vecs, struct iovec *iovecs, unsigned nr_vecs,
off_t offset) off_t offset)
{ {
memset(sqe, 0, sizeof(*sqe)); io_uring_prep_rw(IORING_OP_READV, sqe, fd, iovecs, nr_vecs, offset);
sqe->opcode = IORING_OP_READV; }
sqe->fd = fd;
sqe->off = offset; static inline void io_uring_prep_read_fixed(struct io_uring_sqe *sqe, int fd,
sqe->addr = (unsigned long) iovecs; void *buf, unsigned nbytes,
sqe->len = nr_vecs; off_t offset)
{
io_uring_prep_rw(IORING_OP_READ_FIXED, sqe, fd, buf, nbytes, offset);
} }
static inline void io_uring_prep_writev(struct io_uring_sqe *sqe, int fd, static inline void io_uring_prep_writev(struct io_uring_sqe *sqe, int fd,
struct iovec *iovecs, unsigned nr_vecs, struct iovec *iovecs, unsigned nr_vecs,
off_t offset) off_t offset)
{ {
memset(sqe, 0, sizeof(*sqe)); io_uring_prep_rw(IORING_OP_WRITEV, sqe, fd, iovecs, nr_vecs, offset);
sqe->opcode = IORING_OP_WRITEV; }
sqe->fd = fd;
sqe->off = offset; static inline void io_uring_prep_write_fixed(struct io_uring_sqe *sqe, int fd,
sqe->addr = (unsigned long) iovecs; void *buf, unsigned nbytes,
sqe->len = nr_vecs; off_t offset)
{
io_uring_prep_rw(IORING_OP_WRITE_FIXED, sqe, fd, buf, nbytes, offset);
} }
static inline void io_uring_prep_poll_add(struct io_uring_sqe *sqe, int fd, static inline void io_uring_prep_poll_add(struct io_uring_sqe *sqe, int fd,