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

Fix decoiding of HeapDelete/HeapLock commands

Browse Source
This commit is contained in:
Konstantin Knizhnik
2023-08-16 15:41:49 +03:00
parent 0806a6548e
commit c2a4f432ac
1 changed files with 4 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files
pageserver/src/walrecord.rs
+4 -10
View File
@@ -270,20 +270,17 @@ pub struct XlHeapDelete {
impl XlHeapDelete {
pub fn decode(buf: &mut Bytes) -> XlHeapDelete {
let neon_format = buf.remaining() == pg_constants::SIZE_OF_HEAP_DELETE;
let xmax = buf.get_u32_le();
let offnum = buf.get_u16_le();
let _padding;
let t_cid;
let neon_format;
if buf.remaining() == pg_constants::SIZE_OF_HEAP_DELETE {
// Neon format
if neon_format {
_padding = buf.get_u16_le();
t_cid = buf.get_u32_le();
neon_format = true;
} else {
_padding = 0;
t_cid = 0;
neon_format = false;
}
let infobits_set = buf.get_u8();
let flags = buf.get_u8();
@@ -312,20 +309,17 @@ pub struct XlHeapLock {
impl XlHeapLock {
pub fn decode(buf: &mut Bytes) -> XlHeapLock {
let neon_format = buf.remaining() == pg_constants::SIZE_OF_HEAP_LOCK;
let locking_xid = buf.get_u32_le();
let offnum = buf.get_u16_le();
let _padding;
let t_cid;
let neon_format;
if buf.remaining() == pg_constants::SIZE_OF_HEAP_LOCK {
// Neon format
if neon_format {
_padding = buf.get_u16_le();
t_cid = buf.get_u32_le();
neon_format = true;
} else {
_padding = 0;
t_cid = 0;
neon_format = false;
}
let infobits_set = buf.get_u8();
let flags = buf.get_u8();