xxq250
/
homework-jianmu
1
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

fix worker init

This commit is contained in:
Liu Jicong 2022-03-14 20:51:13 +08:00
parent 36d4ef0af6
commit 6044c75118
1 changed files with 6 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
source/dnode/mgmt/impl/src/dndSnode.c
View File

@ -167,12 +167,15 @@ static int32_t dndStartSnodeWorker(SDnode *pDnode) {
SSnodeMgmt *pMgmt = &pDnode->smgmt; SSnodeMgmt *pMgmt = &pDnode->smgmt;
pMgmt->uniqueWorkers = taosArrayInit(0, sizeof(void *)); pMgmt->uniqueWorkers = taosArrayInit(0, sizeof(void *));
for (int32_t i = 0; i < 2; i++) { for (int32_t i = 0; i < 2; i++) {
SDnodeWorker uniqueWorker; SDnodeWorker *pUniqueWorker = malloc(sizeof(SDnodeWorker));
if (dndInitWorker(pDnode, &uniqueWorker, DND_WORKER_MULTI, "snode-unique", 1, 1, dndProcessSnodeSharedQueue) != 0) { if (pUniqueWorker == NULL) {
return -1;
}
if (dndInitWorker(pDnode, pUniqueWorker, DND_WORKER_MULTI, "snode-unique", 1, 1, dndProcessSnodeSharedQueue) != 0) {
dError("failed to start snode unique worker since %s", terrstr()); dError("failed to start snode unique worker since %s", terrstr());
return -1; return -1;
} }
taosArrayPush(pMgmt->uniqueWorkers, &uniqueWorker); taosArrayPush(pMgmt->uniqueWorkers, &pUniqueWorker);
} }
if (dndInitWorker(pDnode, &pMgmt->sharedWorker, DND_WORKER_SINGLE, "snode-shared", 4, 4, if (dndInitWorker(pDnode, &pMgmt->sharedWorker, DND_WORKER_SINGLE, "snode-shared", 4, 4,
dndProcessSnodeSharedQueue)) { dndProcessSnodeSharedQueue)) {