Skip to content

Commit 5c6dc94

Browse files
committed
perf: remove redundant BufReaders for decompressing tar archives
1 parent 347b25d commit 5c6dc94

File tree

1 file changed

+4
-3
lines changed

1 file changed

+4
-3
lines changed

runtime/src/snapshot_utils.rs

Lines changed: 4 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -2313,14 +2313,15 @@ fn untar_snapshot_create_shared_buffer(
23132313
})
23142314
.unwrap()
23152315
};
2316+
// Apply buffered reader for decoders that do not buffer internally.
23162317
match archive_format {
23172318
ArchiveFormat::TarBzip2 => SharedBuffer::new(BzDecoder::new(BufReader::new(open_file()))),
2318-
ArchiveFormat::TarGzip => SharedBuffer::new(GzDecoder::new(BufReader::new(open_file()))),
2319+
ArchiveFormat::TarGzip => SharedBuffer::new(GzDecoder::new(open_file())),
23192320
ArchiveFormat::TarZstd { .. } => SharedBuffer::new(
2320-
zstd::stream::read::Decoder::new(BufReader::new(open_file())).unwrap(),
2321+
zstd::stream::read::Decoder::new(open_file()).unwrap(),
23212322
),
23222323
ArchiveFormat::TarLz4 => {
2323-
SharedBuffer::new(lz4::Decoder::new(BufReader::new(open_file())).unwrap())
2324+
SharedBuffer::new(lz4::Decoder::new(open_file()).unwrap())
23242325
}
23252326
ArchiveFormat::Tar => SharedBuffer::new(BufReader::new(open_file())),
23262327
}

0 commit comments

Comments
 (0)