| ... | @@ -1,5 +1,12 @@ | ... | @@ -1,5 +1,12 @@ |
| 1 | const std = @import("std"); | 1 | const std = @import("std"); |
| 2 | const nio = @import("./nio.zig"); | 2 | const nio = @import("./nio.zig"); |
| | 3 | const builtin = @import("builtin"); |
| | 4 | const sys_linux = @import("sys-linux"); |
| | 5 | |
| | 6 | const sys = switch (builtin.target.os.tag) { |
| | 7 | .linux => sys_linux, |
| | 8 | else => unreachable, |
| | 9 | }; |
| 3 | | 10 | |
| 4 | pub fn BufferedWriter(comptime buffer_size: usize, comptime WriterType: type) type { | 11 | pub fn BufferedWriter(comptime buffer_size: usize, comptime WriterType: type) type { |
| 5 | return struct { | 12 | return struct { |
| ... | @@ -29,6 +36,15 @@ pub fn BufferedWriter(comptime buffer_size: usize, comptime WriterType: type) ty | ... | @@ -29,6 +36,15 @@ pub fn BufferedWriter(comptime buffer_size: usize, comptime WriterType: type) ty |
| 29 | self.end = new_end; | 36 | self.end = new_end; |
| 30 | return bytes.len; | 37 | return bytes.len; |
| 31 | } | 38 | } |
| | 39 | pub fn writev(self: *Self, iovec: []const sys.struct_iovec) WriteError!usize { |
| | 40 | var total: usize = 0; |
| | 41 | for (iovec) |vec| { |
| | 42 | const len = try write(self, vec.base[0..vec.len]); |
| | 43 | total += len; |
| | 44 | if (len != vec.len) break; |
| | 45 | } |
| | 46 | return total; |
| | 47 | } |
| 32 | | 48 | |
| 33 | pub fn anyWritable(self: *Self) nio.AnyWritable { | 49 | pub fn anyWritable(self: *Self) nio.AnyWritable { |
| 34 | const S = struct { | 50 | const S = struct { |
Meghan Denny <hello@nektro.net> 2026-03-04 03:57:08 -08:00
Signed by SSH key SHA256:4hHJbtBRU58AYXwjL7fkz2fnQHdiye8x1QpTCQ0sHNw