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

Move constants out into file

Browse Source
This commit is contained in:
Arpad Müller
2024-06-10 17:30:56 +02:00
parent 8fcdc22283
commit 88b24e1593
1 changed files with 9 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

17
pageserver/src/tenant/blob_io.rs
View File

@@ -96,6 +96,10 @@ impl<'a> BlockCursor<'a> {
}
}
const BYTE_UNCOMPRESSED: u8 = 0x80;
const BYTE_ZSTD: u8 = BYTE_UNCOMPRESSED | 0x10;
const BYTE_LZ4: u8 = BYTE_UNCOMPRESSED | 0x20;
/// A wrapper of `VirtualFile` that allows users to write blobs.
///
/// If a `BlobWriter` is dropped, the internal buffer will be
@@ -263,9 +267,6 @@ impl<const BUFFERED: bool> BlobWriter<BUFFERED> {
srcbuf.slice(..).into_inner(),
);
}
const UNCOMPRESSED: u8 = 0x80;
const ZSTD: u8 = UNCOMPRESSED | 0x10;
const LZ4: u8 = UNCOMPRESSED | 0x20;
use ImageCompressionAlgorithm::*;
let (high_bit_mask, len_written, srcbuf) = match algorithm {
Some(ZstdLow | Zstd | ZstdHigh) => {
@@ -289,9 +290,9 @@ impl<const BUFFERED: bool> BlobWriter<BUFFERED> {
if compressed.len() < len {
let compressed_len = len;
compressed_buf = Some(compressed);
(ZSTD, compressed_len, slice.into_inner())
(BYTE_ZSTD, compressed_len, slice.into_inner())
} else {
(0x80, len, slice.into_inner())
(BYTE_UNCOMPRESSED, len, slice.into_inner())
}
}
Some(ImageCompressionAlgorithm::LZ4) => {
@@ -300,12 +301,12 @@ impl<const BUFFERED: bool> BlobWriter<BUFFERED> {
if compressed.len() < len {
let compressed_len = len;
compressed_buf = Some(compressed);
(LZ4, compressed_len, slice.into_inner())
(BYTE_LZ4, compressed_len, slice.into_inner())
} else {
(0x80, len, slice.into_inner())
(BYTE_UNCOMPRESSED, len, slice.into_inner())
}
}
None => (0x80, len, srcbuf.slice(..).into_inner()),
None => (BYTE_UNCOMPRESSED, len, srcbuf.slice(..).into_inner()),
};
let mut len_buf = (len_written as u32).to_be_bytes();
len_buf[0] |= high_bit_mask;