From eceb8484112729b4170585d53ecedf3d4d206332 Mon Sep 17 00:00:00 2001 From: openGaussDev Date: Mon, 7 Mar 2022 22:31:56 +0800 Subject: [PATCH] parallel decoding fix initialization bug Offering: openGaussDev More detail: parallel decoding fix initialization bug Match-id-b6cc77c9f7f21082986e421867874c055ffff70a --- .../storage/replication/logical/parallel_decode_worker.cpp | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/src/gausskernel/storage/replication/logical/parallel_decode_worker.cpp b/src/gausskernel/storage/replication/logical/parallel_decode_worker.cpp index e8a98ca9f..43e774f38 100644 --- a/src/gausskernel/storage/replication/logical/parallel_decode_worker.cpp +++ b/src/gausskernel/storage/replication/logical/parallel_decode_worker.cpp @@ -983,10 +983,10 @@ int StartLogicalLogWorkers(char* dbUser, char* dbName, char* slotname, List *opt ParseDecodingOptions(&g_Logicaldispatcher[slotId].pOptions, options); errno_t rc = memcpy_s(g_Logicaldispatcher[slotId].slotName, NAMEDATALEN, slotname, strlen(slotname)); securec_check(rc, "", ""); + + StartLogicalDecodeWorkers(parallelDecodeNum, slotId, dbUser, dbName, slotname); g_Logicaldispatcher[slotId].readWorker = CreateLogicalReadWorker(slotId, dbUser, dbName, slotname, options); g_Logicaldispatcher[slotId].readWorker->tid = StartDecodeReadWorker(g_Logicaldispatcher[slotId].readWorker); - if (g_Logicaldispatcher[slotId].readWorker != NULL) - StartLogicalDecodeWorkers(parallelDecodeNum, slotId, dbUser, dbName, slotname); WaitWorkerReady(slotId); knl_g_parallel_decode_context *gDecodeCxt = g_instance.comm_cxt.pdecode_cxt;