소스 검색

Merge pull request #7077 from fanminshi/consistent_naming

etcdserver: consistent naming in raftReadyHandler
fanmin shi 9 년 전
부모
커밋
0dce29ae57
2개의 변경된 파일3개의 추가작업 그리고 3개의 파일을 삭제
  1. 1 1
      etcdserver/raft.go
  2. 2 2
      etcdserver/server.go

+ 1 - 1
etcdserver/raft.go

@@ -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 {

+ 2 - 2
etcdserver/server.go

@@ -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()