Mirroristas/etcd
2
0
Fork 0
mirror of https://github.com/etcd-io/etcd.git synced 2024-09-27 06:25:44 +00:00
Code Issues Packages Projects Releases Wiki Activity

etcdserver: consistent naming in raftReadyHandler

Browse Source
This commit is contained in:
fanmin shi 2016-12-29 11:27:16 -08:00
parent 67c75606db
commit 2a1bae0c2a
2 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
etcdserver/raft.go
View File

@ -162,7 +162,7 @@ func (r *raftNode) start(rh *raftReadyHandler) {
atomic.StoreUint64(&r.lead, rd.SoftState.Lead) atomic.StoreUint64(&r.lead, rd.SoftState.Lead)
islead = rd.RaftState == raft.StateLeader islead = rd.RaftState == raft.StateLeader
rh.leadershipUpdate() rh.updateLeadership()
} }
if len(rd.ReadStates) != 0 { if len(rd.ReadStates) != 0 {

4
etcdserver/server.go
View File

@ -598,7 +598,7 @@ type etcdProgress struct {
// and helps decouple state machine logic from Raft algorithms. // and helps decouple state machine logic from Raft algorithms.
// TODO: add a state machine interface to apply the commit entries and do snapshot/recover // TODO: add a state machine interface to apply the commit entries and do snapshot/recover
type raftReadyHandler struct { type raftReadyHandler struct {
leadershipUpdate func() updateLeadership func()
updateCommittedIndex func(uint64) updateCommittedIndex func(uint64)
} }
@ -624,7 +624,7 @@ func (s *EtcdServer) run() {
return return
} }
rh := &raftReadyHandler{ rh := &raftReadyHandler{
leadershipUpdate: func() { updateLeadership: func() {
if !s.isLeader() { if !s.isLeader() {
if s.lessor != nil { if s.lessor != nil {
s.lessor.Demote() s.lessor.Demote()