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

enh: terminate on incompletenss of fsm state for dbs of single replica

This commit is contained in:
Benguang Zhao 2023-09-21 20:06:30 +08:00
parent 810678ebcb
commit 233a3c4034
1 changed files with 5 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -1010,8 +1010,11 @@ SSyncNode* syncNodeOpen(SSyncInfo* pSyncInfo, int32_t vnodeVersion) {
sNTrace(pSyncNode, "reset commit index by snapshot"); sNTrace(pSyncNode, "reset commit index by snapshot");
} }
pSyncNode->fsmState = snapshot.state; pSyncNode->fsmState = snapshot.state;
if (pSyncNode->fsmState) { if (pSyncNode->fsmState != SYNC_FSM_STATE_NORMAL) {
sError("vgId:%d, fsm state incomplete.", pSyncNode->vgId); sError("vgId:%d, fsm state is incomplete.", pSyncNode->vgId);
if (pSyncNode->replicaNum == 1) {
goto _error;
}
} }
} }
pSyncNode->commitIndex = commitIndex; pSyncNode->commitIndex = commitIndex;