refact: adjust logging msg for incomplete fsm state
This commit is contained in:
parent
c1f1709d59
commit
d671283b8b
|
@ -155,9 +155,9 @@ int32_t syncNodeOnAppendEntries(SSyncNode* ths, const SRpcMsg* pRpcMsg) {
|
||||||
pMsg->vgId, pMsg->prevLogIndex + 1, pMsg->term, pMsg->prevLogIndex, pMsg->prevLogTerm, pMsg->commitIndex,
|
pMsg->vgId, pMsg->prevLogIndex + 1, pMsg->term, pMsg->prevLogIndex, pMsg->prevLogTerm, pMsg->commitIndex,
|
||||||
pEntry->term);
|
pEntry->term);
|
||||||
|
|
||||||
if (ths->fsmState == SYNC_FSM_STATE_INCOMPLETE) {
|
if (ths->fsmState != SYNC_FSM_STATE_NORMAL) {
|
||||||
pReply->fsmState = ths->fsmState;
|
pReply->fsmState = ths->fsmState;
|
||||||
sError("vgId:%d, not to accept sync log msg due to incomplete fsm state", ths->vgId);
|
sWarn("vgId:%d, unable to accept, due to incomplete fsm state. index:%" PRId64, ths->vgId, pEntry->index);
|
||||||
syncEntryDestroy(pEntry);
|
syncEntryDestroy(pEntry);
|
||||||
goto _SEND_RESPONSE;
|
goto _SEND_RESPONSE;
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in New Issue