mirror of
https://github.com/neondatabase/neon.git
synced 2026-01-07 05:22:56 +00:00
Undo some redundant fixes
This commit is contained in:
@@ -207,7 +207,7 @@ fn walreceiver_main(
|
||||
|
||||
waldecoder.feed_bytes(data);
|
||||
|
||||
while let Ok(Some((lsn, recdata))) = waldecoder.poll_decode() {
|
||||
while let Some((lsn, recdata)) = waldecoder.poll_decode()? {
|
||||
// Save old checkpoint value to compare with it after decoding WAL record
|
||||
let old_checkpoint_bytes = checkpoint.encode();
|
||||
let decoded = decode_wal_record(recdata.clone());
|
||||
|
||||
@@ -303,7 +303,6 @@ impl<'pg> ReceiveWalConn<'pg> {
|
||||
this_timeline.get().set_info(&my_info);
|
||||
/* Need to persist our vote first */
|
||||
this_timeline.get().save_control_file(true)?;
|
||||
this_timeline.get().set_info(&my_info);
|
||||
|
||||
let mut flushed_restart_lsn = Lsn(0);
|
||||
let wal_seg_size = server_info.wal_seg_size as usize;
|
||||
|
||||
Reference in New Issue
Block a user