From 0ee2e16b1755a4ce9254078edeb539b532f1193f Mon Sep 17 00:00:00 2001 From: Konstantin Knizhnik Date: Wed, 11 Aug 2021 09:14:05 +0300 Subject: [PATCH] Walkeeper safe info (#408) * Align prev record CRC on 8-bytes boundary * Upadate safekeeper in-memory status on receiving message from WAL proposer --- walkeeper/src/receive_wal.rs | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/walkeeper/src/receive_wal.rs b/walkeeper/src/receive_wal.rs index 5a701dba17..174b6a52dc 100644 --- a/walkeeper/src/receive_wal.rs +++ b/walkeeper/src/receive_wal.rs @@ -247,8 +247,8 @@ impl ReceiveWalConn { my_info.server.timeline = timeline; info!( - "find_end_of_wal in {:?}: timeline={} flush_lsn={}", - &self.conf.data_dir, timeline, flush_lsn + "find_end_of_wal in {:?}: timeline={} flush_lsn={}, restart_lsn={}", + &self.conf.data_dir, timeline, flush_lsn, my_info.restart_lsn ); /* Report my identifier to proposer */ @@ -332,6 +332,7 @@ 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 */