diff options
| author | daurnimator <quae@daurnimator.com> | 2020-11-19 02:31:55 +1100 |
|---|---|---|
| committer | Andrew Kelley <andrew@ziglang.org> | 2021-01-11 16:48:56 -0700 |
| commit | 01d1a8a783883414bd694731c7c2bfbd054b9a46 (patch) | |
| tree | f81065bb75da1cfe42a03bc6b05d796de9fb2890 /lib/std/fs | |
| parent | e873668d38733d212eef9a317c9679305ff3b82e (diff) | |
| download | zig-01d1a8a783883414bd694731c7c2bfbd054b9a46.tar.gz zig-01d1a8a783883414bd694731c7c2bfbd054b9a46.zip | |
std: use fifo.pump in writeFileAllUnseekable
Diffstat (limited to 'lib/std/fs')
| -rw-r--r-- | lib/std/fs/file.zig | 14 |
1 files changed, 6 insertions, 8 deletions
diff --git a/lib/std/fs/file.zig b/lib/std/fs/file.zig index 7acbc9e2f6..45cb5e3218 100644 --- a/lib/std/fs/file.zig +++ b/lib/std/fs/file.zig @@ -724,14 +724,12 @@ pub const File = struct { try in_file.reader().skipBytes(args.in_offset, .{ .buf_size = 4096 }); - var buffer: [4096]u8 = undefined; - const in_len = args.in_len orelse math.maxInt(u64); - var index: usize = 0; - while (index < in_len) { - const ask = math.min(buffer.len, in_len - index); - const amt = try in_file.read(buffer[0..ask]); - if (amt == 0) break; - index += try self.write(buffer[0..amt]); + var fifo = std.fifo.LinearFifo(u8, .{ .Static = 4096 }).init(); + if (args.in_len) |len| { + var stream = std.io.earlyEOFReader(in_file.reader(), len); + try fifo.pump(stream.reader(), self.writer()); + } else { + try fifo.pump(in_file.reader(), self.writer()); } try self.writevAll(trailers); |
