rust/neon
1
0
Fork 0
mirror of https://github.com/neondatabase/neon.git synced 2026-10-15 08:12:55 +00:00
Code Issues Packages Projects Releases Wiki Activity

compute_tools: disable fast path for safekeeper sync

Browse Source
This commit is contained in:
Erik Grinaker
2024-10-17 10:35:03 +02:00
parent 934dbb61f5
commit c563a25f14
1 changed files with 8 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files
compute_tools/src/compute.rs
+8 -8
View File
@@ -526,6 +526,10 @@ impl ComputeNode {
// Fast path for sync_safekeepers. If they're already synced we get the lsn
// in one roundtrip. If not, we should do a full sync_safekeepers.
//
// NB: currently unused, see: https://github.com/neondatabase/neon/issues/9259. Consider
// removing this, or improving it e.g. by using a different protocol, bumping the safekeeper
// term, or flushing the Safekeeper WAL on STATUS_TIMELINE.
pub fn check_safekeepers_synced(&self, compute_state: &ComputeState) -> Result<Option<Lsn>> {
let start_time = Utc::now();
@@ -629,14 +633,10 @@ impl ComputeNode {
// cannot sync safekeepers.
let lsn = match spec.mode {
ComputeMode::Primary => {
info!("checking if safekeepers are synced");
let lsn = if let Ok(Some(lsn)) = self.check_safekeepers_synced(compute_state) {
lsn
} else {
info!("starting safekeepers syncing");
self.sync_safekeepers(pspec.storage_auth_token.clone())
.with_context(|| "failed to sync safekeepers")?
};
info!("starting safekeepers syncing");
let lsn = self
.sync_safekeepers(pspec.storage_auth_token.clone())
.with_context(|| "failed to sync safekeepers")?;
info!("safekeepers synced at LSN {}", lsn);
lsn
}