rust/neon
1
0
Fork 0
mirror of https://github.com/neondatabase/neon.git synced 2026-06-04 22:10:39 +00:00
Code Issues Packages Projects Releases Wiki Activity

Add the compression algo name

Browse Source
This commit is contained in:
Arpad Müller
2024-06-17 22:25:07 +02:00
parent c5034f0e45
commit e749e73ad6
1 changed files with 3 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
pageserver/src/tenant/storage_layer/image_layer.rs
View File

@@ -402,7 +402,7 @@ impl ImageLayer {
let size = path.metadata()?.size();
let elapsed_ms = start_compression.elapsed().as_millis() as u64;
let start_decompression = Instant::now();
Self::compare_are_equal(path, &compressed_path, ctx).await?;
Self::compare_are_equal(path, &compressed_path, ctx, &image_compression).await?;
let elapsed_decompression_ms = start_decompression.elapsed().as_millis() as u64;
stats.push((
image_compression,
@@ -471,6 +471,7 @@ impl ImageLayer {
path_a: &Utf8Path,
path_b: &Utf8Path,
ctx: &RequestContext,
cmp: &Option<ImageCompressionAlgorithm>,
) -> anyhow::Result<()> {
let mut files = Vec::new();
for path in [path_a, path_b] {
@@ -525,7 +526,7 @@ impl ImageLayer {
let content_b = tree_readers_cursors[1].1.read_blob(offset_b, ctx).await?;
assert_eq!(
content_a, content_b,
"mismatch for key={key} and {path_a}:{path_b}"
"mismatch for key={key} cmp={cmp:?} and {path_a}:{path_b}"
);
}
Ok(())