| ... | @@ -897,13 +897,13 @@ pub const IO_Uring = struct { | ... | @@ -897,13 +897,13 @@ pub const IO_Uring = struct { |
| 897 | self: *IO_Uring, | 897 | self: *IO_Uring, |
| 898 | user_data: u64, | 898 | user_data: u64, |
| 899 | buffers: [*]u8, | 899 | buffers: [*]u8, |
| 900 | buffers_count: usize, | | |
| 901 | buffer_size: usize, | 900 | buffer_size: usize, |
| | 901 | buffers_count: usize, |
| 902 | group_id: usize, | 902 | group_id: usize, |
| 903 | buffer_id: usize, | 903 | buffer_id: usize, |
| 904 | ) !*linux.io_uring_sqe { | 904 | ) !*linux.io_uring_sqe { |
| 905 | const sqe = try self.get_sqe(); | 905 | const sqe = try self.get_sqe(); |
| 906 | io_uring_prep_provide_buffers(sqe, buffers, buffers_count, buffer_size, group_id, buffer_id); | 906 | io_uring_prep_provide_buffers(sqe, buffers, buffer_size, buffers_count, group_id, buffer_id); |
| 907 | sqe.user_data = user_data; | 907 | sqe.user_data = user_data; |
| 908 | return sqe; | 908 | return sqe; |
| 909 | } | 909 | } |
| ... | @@ -1576,8 +1576,8 @@ pub fn io_uring_prep_linkat( | ... | @@ -1576,8 +1576,8 @@ pub fn io_uring_prep_linkat( |
| 1576 | pub fn io_uring_prep_provide_buffers( | 1576 | pub fn io_uring_prep_provide_buffers( |
| 1577 | sqe: *linux.io_uring_sqe, | 1577 | sqe: *linux.io_uring_sqe, |
| 1578 | buffers: [*]u8, | 1578 | buffers: [*]u8, |
| 1579 | num: usize, | | |
| 1580 | buffer_len: usize, | 1579 | buffer_len: usize, |
| | 1580 | num: usize, |
| 1581 | group_id: usize, | 1581 | group_id: usize, |
| 1582 | buffer_id: usize, | 1582 | buffer_id: usize, |
| 1583 | ) void { | 1583 | ) void { |
| ... | @@ -2892,7 +2892,7 @@ test "provide_buffers: read" { | ... | @@ -2892,7 +2892,7 @@ test "provide_buffers: read" { |
| 2892 | // Provide 4 buffers | 2892 | // Provide 4 buffers |
| 2893 | | 2893 | |
| 2894 | { | 2894 | { |
| 2895 | const sqe = try ring.provide_buffers(0xcccccccc, @ptrCast([*]u8, &buffers), buffers.len, buffer_len, group_id, buffer_id); | 2895 | const sqe = try ring.provide_buffers(0xcccccccc, @ptrCast([*]u8, &buffers), buffer_len, buffers.len, group_id, buffer_id); |
| 2896 | try testing.expectEqual(linux.IORING_OP.PROVIDE_BUFFERS, sqe.opcode); | 2896 | try testing.expectEqual(linux.IORING_OP.PROVIDE_BUFFERS, sqe.opcode); |
| 2897 | try testing.expectEqual(@as(i32, buffers.len), sqe.fd); | 2897 | try testing.expectEqual(@as(i32, buffers.len), sqe.fd); |
| 2898 | try testing.expectEqual(@as(u32, buffers[0].len), sqe.len); | 2898 | try testing.expectEqual(@as(u32, buffers[0].len), sqe.len); |
| ... | @@ -2965,7 +2965,7 @@ test "provide_buffers: read" { | ... | @@ -2965,7 +2965,7 @@ test "provide_buffers: read" { |
| 2965 | const reprovided_buffer_id = 2; | 2965 | const reprovided_buffer_id = 2; |
| 2966 | | 2966 | |
| 2967 | { | 2967 | { |
| 2968 | _ = try ring.provide_buffers(0xabababab, @ptrCast([*]u8, &buffers[reprovided_buffer_id]), 1, buffer_len, group_id, reprovided_buffer_id); | 2968 | _ = try ring.provide_buffers(0xabababab, @ptrCast([*]u8, &buffers[reprovided_buffer_id]), buffer_len, 1, group_id, reprovided_buffer_id); |
| 2969 | try testing.expectEqual(@as(u32, 1), try ring.submit()); | 2969 | try testing.expectEqual(@as(u32, 1), try ring.submit()); |
| 2970 | | 2970 | |
| 2971 | const cqe = try ring.copy_cqe(); | 2971 | const cqe = try ring.copy_cqe(); |
| ... | @@ -3024,7 +3024,7 @@ test "remove_buffers" { | ... | @@ -3024,7 +3024,7 @@ test "remove_buffers" { |
| 3024 | // Provide 4 buffers | 3024 | // Provide 4 buffers |
| 3025 | | 3025 | |
| 3026 | { | 3026 | { |
| 3027 | _ = try ring.provide_buffers(0xcccccccc, @ptrCast([*]u8, &buffers), buffers.len, buffer_len, group_id, buffer_id); | 3027 | _ = try ring.provide_buffers(0xcccccccc, @ptrCast([*]u8, &buffers), buffer_len, buffers.len, group_id, buffer_id); |
| 3028 | try testing.expectEqual(@as(u32, 1), try ring.submit()); | 3028 | try testing.expectEqual(@as(u32, 1), try ring.submit()); |
| 3029 | | 3029 | |
| 3030 | const cqe = try ring.copy_cqe(); | 3030 | const cqe = try ring.copy_cqe(); |
| ... | @@ -3113,7 +3113,7 @@ test "provide_buffers: accept/connect/send/recv" { | ... | @@ -3113,7 +3113,7 @@ test "provide_buffers: accept/connect/send/recv" { |
| 3113 | // Provide 4 buffers | 3113 | // Provide 4 buffers |
| 3114 | | 3114 | |
| 3115 | { | 3115 | { |
| 3116 | const sqe = try ring.provide_buffers(0xcccccccc, @ptrCast([*]u8, &buffers), buffers.len, buffer_len, group_id, buffer_id); | 3116 | const sqe = try ring.provide_buffers(0xcccccccc, @ptrCast([*]u8, &buffers), buffer_len, buffers.len, group_id, buffer_id); |
| 3117 | try testing.expectEqual(linux.IORING_OP.PROVIDE_BUFFERS, sqe.opcode); | 3117 | try testing.expectEqual(linux.IORING_OP.PROVIDE_BUFFERS, sqe.opcode); |
| 3118 | try testing.expectEqual(@as(i32, buffers.len), sqe.fd); | 3118 | try testing.expectEqual(@as(i32, buffers.len), sqe.fd); |
| 3119 | try testing.expectEqual(@as(u32, buffer_len), sqe.len); | 3119 | try testing.expectEqual(@as(u32, buffer_len), sqe.len); |
| ... | @@ -3207,7 +3207,7 @@ test "provide_buffers: accept/connect/send/recv" { | ... | @@ -3207,7 +3207,7 @@ test "provide_buffers: accept/connect/send/recv" { |
| 3207 | const reprovided_buffer_id = 2; | 3207 | const reprovided_buffer_id = 2; |
| 3208 | | 3208 | |
| 3209 | { | 3209 | { |
| 3210 | _ = try ring.provide_buffers(0xabababab, @ptrCast([*]u8, &buffers[reprovided_buffer_id]), 1, buffer_len, group_id, reprovided_buffer_id); | 3210 | _ = try ring.provide_buffers(0xabababab, @ptrCast([*]u8, &buffers[reprovided_buffer_id]), buffer_len, 1, group_id, reprovided_buffer_id); |
| 3211 | try testing.expectEqual(@as(u32, 1), try ring.submit()); | 3211 | try testing.expectEqual(@as(u32, 1), try ring.submit()); |
| 3212 | | 3212 | |
| 3213 | const cqe = try ring.copy_cqe(); | 3213 | const cqe = try ring.copy_cqe(); |