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

createlsnmarker for xact dispatch if enable_batch_dispatch is true

Browse Source
This commit is contained in:
movead
2023-09-14 12:00:13 +08:00
parent 321fec4d47
commit 78e11ebf8c
1 changed files with 6 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
src/gausskernel/storage/access/transam/parallel_recovery/dispatcher.cpp
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);