rust/neon
1
0
Fork 0
mirror of https://github.com/neondatabase/neon.git synced 2026-01-04 20:12:54 +00:00
Code Issues Packages Projects Releases Wiki Activity

look up WAL in right directory

Browse Source
This commit is contained in:
Stas Kelvich
2021-08-03 21:25:37 +03:00
committed by arssher
parent ed634ec320
commit 56565c0f58
1 changed files with 14 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

17
walkeeper/src/receive_wal.rs
View File

@@ -242,10 +242,21 @@ impl ReceiveWalConn {
my_info.server.node_id = node_id;
/* Calculate WAL end based on local data */
let (flush_lsn, timeline) = self.timeline.find_end_of_wal(&self.conf.data_dir, true);
let (flush_lsn, timeline) = self.timeline.find_end_of_wal(
&self
.conf
.data_dir
.join(format!("{}", server_info.timeline_id)),
true,
);
my_info.flush_lsn = flush_lsn;
my_info.server.timeline = timeline;
info!(
"find_end_of_wal in {:?}: timeline={} flush_lsn={}",
&self.conf.data_dir, timeline, flush_lsn
);
/* Report my identifier to proposer */
my_info.ser_into(&mut self.stream_out)?;
@@ -284,8 +295,8 @@ impl ReceiveWalConn {
}
info!(
"Start streaming from timeline {} tenant {} address {:?}",
server_info.timeline_id, server_info.tenant_id, self.peer_addr,
"Start streaming from timeline {} tenant {} address {:?} flush_lsn={}",
server_info.timeline_id, server_info.tenant_id, self.peer_addr, my_info.flush_lsn
);
// Main loop