如果已经把最新的log更新了,那就多等一会,反之,很快就广播AppendEntries(也就是心跳消息)
func (rf *Raft) LeaderState() {
time.Sleep(10 * time.Millisecond) if rf.LastApplied == rf.CommitIndex { time.Sleep(25 * time.Millisecond) } go rf.BroadcastAppendEntriesRPC()}本文共 284 字,大约阅读时间需要 1 分钟。
如果已经把最新的log更新了,那就多等一会,反之,很快就广播AppendEntries(也就是心跳消息)
func (rf *Raft) LeaderState() {
time.Sleep(10 * time.Millisecond) if rf.LastApplied == rf.CommitIndex { time.Sleep(25 * time.Millisecond) } go rf.BroadcastAppendEntriesRPC()}转载于:https://www.cnblogs.com/yanchengwang/p/5913777.html