From baf8800b96dc1a11d3932114f2673956fd805d58 Mon Sep 17 00:00:00 2001 From: Konstantin Knizhnik Date: Fri, 9 Jul 2021 14:45:21 +0300 Subject: [PATCH] Fix incorrect mask in wldecoder --- pageserver/src/waldecoder.rs | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/pageserver/src/waldecoder.rs b/pageserver/src/waldecoder.rs index cfb9f1355c..81d8d6b924 100644 --- a/pageserver/src/waldecoder.rs +++ b/pageserver/src/waldecoder.rs @@ -731,7 +731,7 @@ pub fn decode_wal_record(record: Bytes) -> DecodedWALRecord { // 5. Handle a few special record types that modify blocks without registering // them with the standard mechanism. if xlogrec.xl_rmid == pg_constants::RM_HEAP_ID { - let info = xlogrec.xl_info & pg_constants::XLOG_XACT_OPMASK; + let info = xlogrec.xl_info & pg_constants::XLR_RMGR_INFO_MASK; let blkno = blocks[0].blkno / pg_constants::HEAPBLOCKS_PER_PAGE as u32; if info == pg_constants::XLOG_HEAP_INSERT { let xlrec = XlHeapInsert::decode(&mut buf); @@ -785,7 +785,7 @@ pub fn decode_wal_record(record: Bytes) -> DecodedWALRecord { } } } else if xlogrec.xl_rmid == pg_constants::RM_HEAP2_ID { - let info = xlogrec.xl_info & pg_constants::XLOG_XACT_OPMASK; + let info = xlogrec.xl_info & pg_constants::XLR_RMGR_INFO_MASK; if info == pg_constants::XLOG_HEAP2_MULTI_INSERT { let xlrec = XlHeapMultiInsert::decode(&mut buf); if (xlrec.flags