Lohax
/
openGauss-server
forked from huawei/openGauss-server
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

parallel decoding fix initialization bug 

Offering: openGaussDev

More detail: parallel decoding fix initialization bug

Match-id-b6cc77c9f7f21082986e421867874c055ffff70a
This commit is contained in:
openGaussDev 2022-03-07 22:31:56 +08:00 committed by yanghao
parent d45634be91
commit eceb848411
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
src/gausskernel/storage/replication/logical/parallel_decode_worker.cpp
View File

@ -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;