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

解决延时不生效问题

Browse Source
This commit is contained in:
MuJinqiang
2021-02-07 22:39:32 +08:00
parent 27ef270368
commit 32df3a02f4
1 changed files with 6 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@ -7628,11 +7628,14 @@ static bool RecoveryApplyDelay(const XLogReaderState *record)
}
xactInfo = XLogRecGetInfo(record) & (~XLR_INFO_MASK);
if (xactInfo != XLOG_XACT_COMMIT) {
if (xactInfo == XLOG_XACT_COMMIT) {
xtime = ((xl_xact_commit *)XLogRecGetData(record))->xact_time;
} else if (xactInfo == XLOG_XACT_COMMIT_COMPACT) {
xtime = ((xl_xact_commit_compact *)XLogRecGetData(record))->xact_time;
} else {
return false;
}
xtime = ((xl_xact_commit *)XLogRecGetData(record))->xact_time;
t_thrd.xlog_cxt.recoveryDelayUntilTime =
TimestampTzPlusMilliseconds(xtime, t_thrd.xlog_cxt.recovery_min_apply_delay);