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

!749 解决延时回放问题

Browse Source 
Merge pull request !749 from mujinqiang/fixdelay
This commit is contained in:
opengauss-bot
2021-03-02 14:40:09 +08:00
committed by Gitee
parent 71b1ba1b19 f6cdf958ca
commit 5952e06000
1 changed files with 4 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@ -7628,7 +7628,7 @@ static bool RecoveryApplyDelay(const XLogReaderState *record)
}
xactInfo = XLogRecGetInfo(record) & (~XLR_INFO_MASK);
if (xactInfo == XLOG_XACT_COMMIT) {
if ((xactInfo == XLOG_XACT_COMMIT) || (xactInfo == XLOG_STANDBY_CSN_COMMITTING)) {
xtime = ((xl_xact_commit *)XLogRecGetData(record))->xact_time;
} else if (xactInfo == XLOG_XACT_COMMIT_COMPACT) {
xtime = ((xl_xact_commit_compact *)XLogRecGetData(record))->xact_time;
@ -7659,6 +7659,9 @@ static bool RecoveryApplyDelay(const XLogReaderState *record)
TimestampDifference(GetCurrentTimestamp(), t_thrd.xlog_cxt.recoveryDelayUntilTime,
&secs, &microsecs);
/* To clear LSNMarker item that has not been processed in pageworker*/
ProcTxnWorkLoad(false);
/* NB: We're ignoring waits below min_apply_delay's resolution. */
if (secs <= 0 && microsecs / 1000 <= 0) {
break;