aboutsummaryrefslogtreecommitdiff
path: root/lib/std/fs
diff options
context:
space:
mode:
authordaurnimator <quae@daurnimator.com>2020-11-19 02:31:55 +1100
committerAndrew Kelley <andrew@ziglang.org>2021-01-11 16:48:56 -0700
commit01d1a8a783883414bd694731c7c2bfbd054b9a46 (patch)
treef81065bb75da1cfe42a03bc6b05d796de9fb2890 /lib/std/fs
parente873668d38733d212eef9a317c9679305ff3b82e (diff)
downloadzig-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.zig14
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);