Raft协议详解-leader发送心跳代码go

时间:2016-09-27 19:19:31   收藏:0   阅读:328

如果已经把最新的log更新了,那就多等一会,反之,很快就广播AppendEntries(也就是心跳消息)

func (rf *Raft) LeaderState() {
time.Sleep(10 * time.Millisecond)
if rf.LastApplied == rf.CommitIndex {
time.Sleep(25 * time.Millisecond)
}
go rf.BroadcastAppendEntriesRPC()
}

原文:http://www.cnblogs.com/yanchengwang/p/5913777.html

评论(0
© 2014 bubuko.com 版权所有 - 联系我们:wmxa8@hotmail.com
打开技术之扣,分享程序人生!