From e639c93745b718a5b03b2e8a25a88f89651209b6 Mon Sep 17 00:00:00 2001 From: congzhou2603 Date: Sun, 29 Sep 2024 21:01:45 +0800 Subject: [PATCH] =?UTF-8?q?=E3=80=90bugfix=E3=80=91=E4=BF=AE=E5=A4=8D?= =?UTF-8?q?=E5=AE=9E=E6=97=B6=E6=9E=84=E5=BB=BA=E6=9C=89=E6=A6=82=E7=8E=87?= =?UTF-8?q?=E5=87=BA=E7=8E=B0=E5=BE=80=E5=B7=B2=E7=BB=8F=E8=A2=AB=E9=87=8A?= =?UTF-8?q?=E6=94=BE=E7=9A=84hash=E6=8F=92=E5=85=A5redoEntry=E7=9A=84?= =?UTF-8?q?=E9=97=AE=E9=A2=98?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../access/transam/ondemand_extreme_rto/page_redo.cpp | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/src/gausskernel/storage/access/transam/ondemand_extreme_rto/page_redo.cpp b/src/gausskernel/storage/access/transam/ondemand_extreme_rto/page_redo.cpp index 8657987ced..6be30f753b 100644 --- a/src/gausskernel/storage/access/transam/ondemand_extreme_rto/page_redo.cpp +++ b/src/gausskernel/storage/access/transam/ondemand_extreme_rto/page_redo.cpp @@ -1426,7 +1426,7 @@ static void OnDemandPageManagerProcSegParseState(XLogRecParseState *preState, XL OnDemandPageManagerRedoSegParseState(preState); } -static bool WaitPrimaryDoCheckpointAndAllPRTrackEmpty(XLogRecParseState *preState, HTAB *redoItemHash) +static bool WaitPrimaryDoCheckpointAndAllPRTrackEmpty(XLogRecParseState *preState) { if (!SS_ONDEMAND_REALTIME_BUILD_NORMAL) { return false; @@ -1534,14 +1534,14 @@ void PageManagerRedoParseState(XLogRecParseState *preState) return; } - HTAB *hashMap = g_dispatcher->pageLines[g_redoWorker->slotId].managerThd->redoItemHashCtrl->hTab; XLogRecParseType type = GetCurrentXLogRecParseType(preState); - if (type == PARSE_TYPE_DDL && WaitPrimaryDoCheckpointAndAllPRTrackEmpty(preState, hashMap)) { + if (type == PARSE_TYPE_DDL && WaitPrimaryDoCheckpointAndAllPRTrackEmpty(preState)) { ReleaseBlockParseStateIfNotReplay(preState); return; } PageManagerPruneIfRealtimeBuildFailover(); + HTAB *hashMap = g_dispatcher->pageLines[g_redoWorker->slotId].managerThd->redoItemHashCtrl->hTab; switch (preState->blockparse.blockhead.block_valid) { case BLOCK_DATA_MAIN_DATA_TYPE: case BLOCK_DATA_UNDO_TYPE: -- Gitee