!4144 修复redo性能优化patch导致的hung的问题

Merge pull request !4144 from Movead/master
This commit is contained in:
opengauss_bot
2023-09-14 07:17:06 +00:00
committed by Gitee

View File

@ -727,6 +727,12 @@ static void DispatchToOnePageWorker(XLogReaderState *record, const RelFileNode &
*/
static void DispatchTxnRecord(XLogReaderState *record, List *expectedTLIs, TimestampTz recordXTime, bool imcheckpoint)
{
if (g_instance.attr.attr_storage.enable_batch_dispatch) {
for (uint32 i = 0; i < g_dispatcher->pageWorkerCount; i++) {
RedoItem *item = CreateLSNMarker(record, expectedTLIs, false);
AddPageRedoItem(g_dispatcher->pageWorkers[i], item);
}
}
RedoItem *trxnItem = CreateRedoItem(record, 1, ANY_WORKER, expectedTLIs, recordXTime, true);
trxnItem->imcheckpoint = imcheckpoint; /* immdiate checkpoint set imcheckpoint */
AddTxnRedoItem(g_dispatcher->txnWorker, trxnItem);