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

fix(sync): when FpApplyQueueItems return -1, break loop

This commit is contained in:
Minghao Li 2022-12-05 20:24:25 +08:00
parent a1ed4b334c
commit b107518b00
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
source/libs/sync/src/syncMain.c
View File

@ -1225,7 +1225,7 @@ void syncNodePreClose(SSyncNode* pSyncNode) {
while (1) { while (1) {
int32_t aqItems = pSyncNode->pFsm->FpApplyQueueItems(pSyncNode->pFsm); int32_t aqItems = pSyncNode->pFsm->FpApplyQueueItems(pSyncNode->pFsm);
sTrace("vgId:%d, pre close, %d items in apply queue", pSyncNode->vgId, aqItems); sTrace("vgId:%d, pre close, %d items in apply queue", pSyncNode->vgId, aqItems);
if (aqItems == 0) { if (aqItems == 0 || aqItems == -1) {
break; break;
} }
taosMsleep(20); taosMsleep(20);