From 0fdeca882c6a5619b70e259844170bfb6032a68f Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Arpad=20M=C3=BCller?= <arpad@neon.tech>
Date: Sat, 15 Jun 2024 00:24:25 +0200
Subject: [PATCH] Fix tests

---
 pageserver/src/tenant/blob_io.rs | 8 ++++----
 1 file changed, 4 insertions(+), 4 deletions(-)

diff --git a/pageserver/src/tenant/blob_io.rs b/pageserver/src/tenant/blob_io.rs
index 4c2cb4c23a..0fb7587d5d 100644
--- a/pageserver/src/tenant/blob_io.rs
+++ b/pageserver/src/tenant/blob_io.rs
@@ -116,11 +116,11 @@ impl<'a> BlockCursor<'a> {
                 decoder.write_all(buf_to_write).await?;
                 decoder.flush().await?;
             } else if compression_bits == BYTE_LZ4 {
-                let decompressed = lz4_flex::block::decompress(&buf_to_write, 128 as usize)
-                    .map_err(|_| {
+                let decompressed = lz4_flex::block::decompress_size_prepended(&buf_to_write)
+                    .map_err(|e| {
                         std::io::Error::new(
                             std::io::ErrorKind::InvalidData,
-                            "lz4 decompression error",
+                            format!("lz4 decompression error: {e:?}"),
                         )
                     })?;
                 dstbuf.extend_from_slice(&decompressed);
@@ -334,7 +334,7 @@ impl<const BUFFERED: bool> BlobWriter<BUFFERED> {
                     }
                     Some(ImageCompressionAlgorithm::LZ4) => {
                         let slice = srcbuf.slice(..);
-                        let compressed = lz4_flex::block::compress(&slice[..]);
+                        let compressed = lz4_flex::block::compress_prepend_size(&slice[..]);
                         if compressed.len() < len {
                             let compressed_len = compressed.len();
                             compressed_buf = Some(compressed);