File tree Expand file tree Collapse file tree 1 file changed +0
-11
lines changed
postgres-protocol/src/message Expand file tree Collapse file tree 1 file changed +0
-11
lines changed Original file line number Diff line number Diff 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> {
983978pub 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
You can’t perform that action at this time.
0 commit comments