fix(raft): fix BC-1333, the leader node cannot be selected
This commit is contained in:
parent
9c9078c8e5
commit
3212c66f60
|
@ -355,10 +355,10 @@ func (n *Node) run() {
|
||||||
msgInflight := n.ramLastIndex() > n.appliedIndex+1
|
msgInflight := n.ramLastIndex() > n.appliedIndex+1
|
||||||
if msgInflight {
|
if msgInflight {
|
||||||
n.logger.Debugf("There are in flight blocks, new leader should not serve requests")
|
n.logger.Debugf("There are in flight blocks, new leader should not serve requests")
|
||||||
continue
|
} else {
|
||||||
|
n.justElected = false
|
||||||
|
n.mempool.UpdateLeader(n.leader)
|
||||||
}
|
}
|
||||||
n.justElected = false
|
|
||||||
n.mempool.UpdateLeader(n.leader)
|
|
||||||
}
|
}
|
||||||
|
|
||||||
// 3: AsyncSend all Messages to the nodes named in the To field.
|
// 3: AsyncSend all Messages to the nodes named in the To field.
|
||||||
|
|
Loading…
Reference in New Issue