rust/neon
1
0
Fork 0
mirror of https://github.com/neondatabase/neon.git synced 2026-01-07 13:32:57 +00:00
Code Issues Packages Projects Releases Wiki Activity

Revert "Walkeeper safe info (#408)"

Browse Source 
Temporary revert commit 0ee2e16b17 as it leads to
safekeeper state deserialization failure. Let's sort that out and get it back.
This commit is contained in:
Arseny Sher
2021-08-11 16:26:35 +03:00
parent 0ee2e16b17
commit 5f0fd093d7
1 changed files with 2 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
walkeeper/src/receive_wal.rs
View File

@@ -247,8 +247,8 @@ impl ReceiveWalConn {
my_info.server.timeline = timeline;
info!(
"find_end_of_wal in {:?}: timeline={} flush_lsn={}, restart_lsn={}",
&self.conf.data_dir, timeline, flush_lsn, my_info.restart_lsn
"find_end_of_wal in {:?}: timeline={} flush_lsn={}",
&self.conf.data_dir, timeline, flush_lsn
);
/* Report my identifier to proposer */
@@ -332,7 +332,6 @@ impl ReceiveWalConn {
* maximum (vcl) determined by WAL proposer during handshake.
* Switching epoch means that node completes recovery and start writing in the WAL new data.
*/
self.timeline.get().set_info(&my_info);
if my_info.epoch < prop.epoch && end_pos > max(my_info.flush_lsn, prop.vcl) {
info!("Switch to new epoch {}", prop.epoch);
my_info.epoch = prop.epoch; /* bump epoch */