hcq/openGauss-server
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix CreateRestartPoint core not correct in extreme rto

Browse Source
This commit is contained in:
yanghao
2021-08-04 14:50:35 +08:00
parent 4b8e3965e9
commit d3b5f40c31
1 changed files with 5 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
src/gausskernel/storage/access/transam/xlog.cpp
View File

@ -11794,7 +11794,7 @@ bool CreateRestartPoint(int flags)
} else if (ENABLE_INCRE_CKPT) {
g_instance.ckpt_cxt_ctl->full_ckpt_redo_ptr = lastCheckPoint.redo;
(void)LWLockAcquire(g_instance.ckpt_cxt_ctl->prune_queue_lock, LW_EXCLUSIVE);
g_instance.ckpt_cxt_ctl->full_ckpt_expected_flush_loc = get_loc_for_lsn(lastCheckPoint.redo);
g_instance.ckpt_cxt_ctl->full_ckpt_expected_flush_loc = get_loc_for_lsn(lastCheckPointRecPtr);
LWLockRelease(g_instance.ckpt_cxt_ctl->prune_queue_lock);
pg_write_barrier();
@ -11821,11 +11821,11 @@ bool CreateRestartPoint(int flags)
XLByteToSeg(t_thrd.shemem_ptr_cxt.ControlFile->checkPointCopy.redo, _logSegNo);
if (ENABLE_INCRE_CKPT) {
XLogRecPtr MinRecLSN = ckpt_get_min_rec_lsn();
if (!XLogRecPtrIsInvalid(MinRecLSN) && XLByteLT(MinRecLSN, lastCheckPoint.redo)) {
if (!XLogRecPtrIsInvalid(MinRecLSN) && XLByteLT(MinRecLSN, lastCheckPointRecPtr)) {
ereport(WARNING, (errmsg("current dirty page list head recLSN %08X/%08X smaller than redo lsn %08X/%08X",
(uint32)(MinRecLSN >> XLOG_LSN_SWAP), (uint32)MinRecLSN,
(uint32)(lastCheckPoint.redo >> XLOG_LSN_SWAP),
(uint32)lastCheckPoint.redo)));
(uint32)(lastCheckPointRecPtr >> XLOG_LSN_SWAP),
(uint32)lastCheckPointRecPtr)));
LWLockRelease(CheckpointLock);
smgrsync_with_absorption();
gstrace_exit(GS_TRC_ID_CreateRestartPoint);
@ -17713,4 +17713,4 @@ extern bool IsValidArchiverStandby(WalSnd* walsnd)
} else {
return false;
}
}
}