Skip to content

Commit c4a2356

Browse files
VladLazararpad-m
authored andcommitted
backend: pack next record LSN into the encoded message (#33)
This field only needs to be read after the batch is decoded, so we can move into the body to get more efficient encoding.
1 parent e66235a commit c4a2356

File tree

1 file changed

+0
-11
lines changed

1 file changed

+0
-11
lines changed

postgres-protocol/src/message/backend.rs

Lines changed: 0 additions & 11 deletions
Original file line numberDiff line numberDiff line change
@@ -375,15 +375,10 @@ impl ReplicationMessage<Bytes> {
375375
INTERPRETED_WAL_RECORD_TAG => {
376376
let streaming_lsn = buf.read_u64::<BigEndian>()?;
377377
let commit_lsn = buf.read_u64::<BigEndian>()?;
378-
let next_record_lsn = match buf.read_u64::<BigEndian>()? {
379-
0 => None,
380-
lsn => Some(lsn),
381-
};
382378

383379
ReplicationMessage::RawInterpretedWalRecords(RawInterpretedWalRecordsBody {
384380
streaming_lsn,
385381
commit_lsn,
386-
next_record_lsn,
387382
data: buf.read_all(),
388383
})
389384
}
@@ -983,7 +978,6 @@ impl<D> XLogDataBody<D> {
983978
pub struct RawInterpretedWalRecordsBody<D> {
984979
streaming_lsn: u64,
985980
commit_lsn: u64,
986-
next_record_lsn: Option<u64>,
987981
data: D,
988982
}
989983

@@ -998,11 +992,6 @@ impl<D> RawInterpretedWalRecordsBody<D> {
998992
self.commit_lsn
999993
}
1000994

1001-
#[inline]
1002-
pub fn next_record_lsn(&self) -> Option<u64> {
1003-
self.next_record_lsn
1004-
}
1005-
1006995
#[inline]
1007996
pub fn data(&self) -> &D {
1008997
&self.data

0 commit comments

Comments
 (0)