mirror/zig
1
0
Fork 0
mirror of https://github.com/ziglang/zig.git synced 2025-12-06 22:33:08 +00:00
Code Issues Packages Projects Releases Wiki Activity

io_uring: add poll_update

Browse Source 
Add method from liburing to queue (but not submit) a SQE to update the
user data of an existing poll operation.
This commit is contained in:
Kenta Iwasaki 2021-11-10 16:35:11 +00:00 committed by Andrew Kelley
parent 1d55705fa4
commit 09c17acf02
1 changed files with 38 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

39
lib/std/os/linux/io_uring.zig
View File

@ -634,6 +634,22 @@ pub const IO_Uring = struct {
return sqe; return sqe;
} }
/// Queues (but does not submit) an SQE to update the user data of an existing poll
/// operation. Returns a pointer to the SQE.
pub fn poll_update(
self: *IO_Uring,
user_data: u64,
old_user_data: u64,
new_user_data: u64,
poll_mask: u32,
flags: u32,
) !*io_uring_sqe {
const sqe = try self.get_sqe();
io_uring_prep_poll_update(sqe, old_user_data, new_user_data, poll_mask, flags);
sqe.user_data = user_data;
return sqe;
}
/// Queues (but does not submit) an SQE to perform an `fallocate(2)`. /// Queues (but does not submit) an SQE to perform an `fallocate(2)`.
/// Returns a pointer to the SQE. /// Returns a pointer to the SQE.
pub fn fallocate( pub fn fallocate(
@ -993,6 +1009,16 @@ pub fn io_uring_prep_write_fixed(sqe: *io_uring_sqe, fd: os.fd_t, buffer: *os.io
sqe.buf_index = buffer_index; sqe.buf_index = buffer_index;
} }
/// Poll masks previously used to comprise of 16 bits in the flags union of
/// a SQE, but were then extended to comprise of 32 bits in order to make
/// room for additional option flags. To ensure that the correct bits of
/// poll masks are consistently and properly read across multiple kernel
/// versions, poll masks are enforced to be little-endian.
/// https://www.spinics.net/lists/io-uring/msg02848.html
pub inline fn __io_uring_prep_poll_mask(poll_mask: u32) u32 {
return std.mem.nativeToLittle(u32, poll_mask);
}
pub fn io_uring_prep_accept( pub fn io_uring_prep_accept(
sqe: *io_uring_sqe, sqe: *io_uring_sqe,
fd: os.fd_t, fd: os.fd_t,
@ -1099,7 +1125,7 @@ pub fn io_uring_prep_poll_add(
poll_mask: u32, poll_mask: u32,
) void { ) void {
io_uring_prep_rw(.POLL_ADD, sqe, fd, @ptrToInt(@as(?*c_void, null)), 0, 0); io_uring_prep_rw(.POLL_ADD, sqe, fd, @ptrToInt(@as(?*c_void, null)), 0, 0);
sqe.rw_flags = std.mem.nativeToLittle(u32, poll_mask); sqe.rw_flags = __io_uring_prep_poll_mask(poll_mask);
} }
pub fn io_uring_prep_poll_remove( pub fn io_uring_prep_poll_remove(
@ -1109,6 +1135,17 @@ pub fn io_uring_prep_poll_remove(
io_uring_prep_rw(.POLL_REMOVE, sqe, -1, target_user_data, 0, 0); io_uring_prep_rw(.POLL_REMOVE, sqe, -1, target_user_data, 0, 0);
} }
pub fn io_uring_prep_poll_update(
sqe: *io_uring_sqe,
old_user_data: u64,
new_user_data: u64,
poll_mask: u32,
flags: u32,
) void {
io_uring_prep_rw(.POLL_REMOVE, sqe, -1, old_user_data, flags, new_user_data);
sqe.rw_flags = __io_uring_prep_poll_mask(poll_mask);
}
pub fn io_uring_prep_fallocate( pub fn io_uring_prep_fallocate(
sqe: *io_uring_sqe, sqe: *io_uring_sqe,
fd: os.fd_t, fd: os.fd_t,