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

!6482 回合6479

Browse Source 
Merge pull request !6482 from 陈栋/cherry-pick-1727404959
This commit is contained in:
opengauss_bot
2024-09-27 03:10:52 +00:00
committed by Gitee
parent 3c83075609 4cfcf03287
commit c18f9cdf82
1 changed files with 5 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
src/gausskernel/storage/access/transam/ondemand_extreme_rto/page_redo.cpp
View File

@ -4261,6 +4261,9 @@ void GetOndemandRecoveryStatus(ondemand_recovery_stat *stat)
stat->hmpTotalBlkNum = g_dispatcher->parseManager.memctl.totalblknum;
stat->trxnQueueNum = SPSCGetQueueCount(g_dispatcher->trxnQueue);
stat->segQueueNum = SPSCGetQueueCount(g_dispatcher->segQueue);
stat->recordItemNum = pg_atomic_read_u32(&g_dispatcher->curItemNum);
stat->recordItemMemUsed = stat->recordItemNum * sizeof(RedoItem) +
pg_atomic_read_u64(&g_dispatcher->curItemRecordBufMemSize);
} else {
stat->checkpointPtr = InvalidXLogRecPtr;
stat->replayedPtr = InvalidXLogRecPtr;
@ -4268,14 +4271,13 @@ void GetOndemandRecoveryStatus(ondemand_recovery_stat *stat)
stat->hmpTotalBlkNum = 0;
stat->trxnQueueNum = 0;
stat->segQueueNum = 0;
stat->recordItemNum = 0;
stat->recordItemMemUsed = 0;
}
stat->inOndemandRecovery = SS_IN_ONDEMAND_RECOVERY;
stat->ondemandRecoveryStatus = g_instance.dms_cxt.SSRecoveryInfo.cluster_ondemand_status;
stat->realtimeBuildStatus = g_instance.dms_cxt.SSRecoveryInfo.ondemand_realtime_build_status;
stat->recoveryPauseStatus = g_instance.dms_cxt.SSRecoveryInfo.ondemand_recovery_pause_status;
stat->recordItemNum = pg_atomic_read_u32(&g_dispatcher->curItemNum);
stat->recordItemMemUsed = stat->recordItemNum * sizeof(RedoItem) +
pg_atomic_read_u64(&g_dispatcher->curItemRecordBufMemSize);
}
void RealtimeBuildReleaseRecoveryLatch(int code, Datum arg) {