rust/neon
1
0
Fork 0
mirror of https://github.com/neondatabase/neon.git synced 2026-01-16 18:02:56 +00:00
Code Issues Packages Projects Releases Wiki Activity

Handle lack of checkpoint in basebackup

Browse Source
This commit is contained in:
Konstantin Knizhnik
2024-10-03 17:25:38 +03:00
parent 953ad21104
commit 92ae912ebe
1 changed files with 22 additions and 22 deletions
Download Patch File Download Diff File Expand all files Collapse all files

44
pageserver/src/basebackup.rs
View File

@@ -258,29 +258,29 @@ where
async fn send_tarball(mut self) -> Result<(), BasebackupError> {
// TODO include checksum
let checkpoint = CheckPoint::decode(
&self
.timeline
.get_checkpoint(self.lsn, self.ctx)
.await
.context("failed to get checkpoint bytes")?,
)
.context("deserialize checkpoint")?;
let checkpoint_end =
checkpoint.redo + ((XLOG_SIZE_OF_XLOG_RECORD + 8 + SIZEOF_CHECKPOINT) as u64);
let checkpoint_end_lsn = Lsn(checkpoint_end
+ (if (XLOG_BLCKSZ as u64) - checkpoint.redo % (XLOG_BLCKSZ as u64)
< (SIZEOF_CHECKPOINT as u64)
{
if (checkpoint_end & ((WAL_SEGMENT_SIZE - 1) as u64)) < (XLOG_BLCKSZ as u64) {
XLOG_SIZE_OF_XLOG_LONG_PHD
let normal_shutdown = if let Ok(checkpoint_bytes) =
self.timeline.get_checkpoint(self.lsn, self.ctx).await
{
let checkpoint =
CheckPoint::decode(&checkpoint_bytes).context("deserialize checkpoint")?;
let checkpoint_end =
checkpoint.redo + ((XLOG_SIZE_OF_XLOG_RECORD + 8 + SIZEOF_CHECKPOINT) as u64);
let checkpoint_end_lsn = Lsn(checkpoint_end
+ (if (XLOG_BLCKSZ as u64) - checkpoint.redo % (XLOG_BLCKSZ as u64)
< (SIZEOF_CHECKPOINT as u64)
{
if (checkpoint_end & ((WAL_SEGMENT_SIZE - 1) as u64)) < (XLOG_BLCKSZ as u64) {
XLOG_SIZE_OF_XLOG_LONG_PHD
} else {
XLOG_SIZE_OF_XLOG_SHORT_PHD
}
} else {
XLOG_SIZE_OF_XLOG_SHORT_PHD
}
} else {
0
}) as u64);
let normal_shutdown = checkpoint_end_lsn == self.lsn;
0
}) as u64);
checkpoint_end_lsn == self.lsn
} else {
false
};
let lazy_slru_download = self.timeline.get_lazy_slru_download() && !self.full_backup;