From 15c0e1351a9514acbe7fdbfd1bf85f36824d07bf Mon Sep 17 00:00:00 2001 From: Konstantin Knizhnik Date: Fri, 16 Feb 2024 10:33:26 +0200 Subject: [PATCH] Fix messages tags in PS serialize --- libs/pageserver_api/src/models.rs | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) diff --git a/libs/pageserver_api/src/models.rs b/libs/pageserver_api/src/models.rs index 76f0e8c0e0..80026e13f0 100644 --- a/libs/pageserver_api/src/models.rs +++ b/libs/pageserver_api/src/models.rs @@ -923,7 +923,7 @@ impl PagestreamFeMessage { match self { Self::Exists(req) => { - bytes.put_u8(0); + bytes.put_u8(10); bytes.put_u64(req.horizon.0); bytes.put_u64(req.lsn.0); bytes.put_u32(req.rel.spcnode); @@ -933,7 +933,7 @@ impl PagestreamFeMessage { } Self::Nblocks(req) => { - bytes.put_u8(1); + bytes.put_u8(11); bytes.put_u64(req.horizon.0); bytes.put_u64(req.lsn.0); bytes.put_u32(req.rel.spcnode); @@ -943,7 +943,7 @@ impl PagestreamFeMessage { } Self::GetPage(req) => { - bytes.put_u8(2); + bytes.put_u8(12); bytes.put_u64(req.horizon.0); bytes.put_u64(req.lsn.0); bytes.put_u32(req.rel.spcnode); @@ -954,14 +954,14 @@ impl PagestreamFeMessage { } Self::DbSize(req) => { - bytes.put_u8(3); + bytes.put_u8(13); bytes.put_u64(req.horizon.0); bytes.put_u64(req.lsn.0); bytes.put_u32(req.dbnode); } Self::GetSlruSegment(req) => { - bytes.put_u8(4); + bytes.put_u8(14); bytes.put_u64(req.horizon.0); bytes.put_u64(req.lsn.0); bytes.put_u8(req.kind);