From 32df3a02f493060e7faa42713f075911aac51edf Mon Sep 17 00:00:00 2001 From: MuJinqiang <1165845907@qq.com> Date: Sun, 7 Feb 2021 22:39:32 +0800 Subject: [PATCH] =?UTF-8?q?=E8=A7=A3=E5=86=B3=E5=BB=B6=E6=97=B6=E4=B8=8D?= =?UTF-8?q?=E7=94=9F=E6=95=88=E9=97=AE=E9=A2=98?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- src/gausskernel/storage/access/transam/xlog.cpp | 9 ++++++--- 1 file changed, 6 insertions(+), 3 deletions(-) diff --git a/src/gausskernel/storage/access/transam/xlog.cpp b/src/gausskernel/storage/access/transam/xlog.cpp index 94e41a9a6..07e8fa264 100755 --- a/src/gausskernel/storage/access/transam/xlog.cpp +++ b/src/gausskernel/storage/access/transam/xlog.cpp @@ -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);