vitalif
/
etcd
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

raft: remove unnecessary funcs in raft.go

release-2.0
Xiang Li 2014-12-25 17:04:33 -08:00
parent 7d866dbc44
commit fc96a9e4a7
3 changed files with 8 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
raft/node.go
View File

@ -244,19 +244,19 @@ func (n *node) run(r *raft) {
}
}
if lead != r.leader() {
if lead != r.lead {
if r.hasLeader() {
if lead == None {
log.Printf("raft.node: %x elected leader %x at term %d", r.id, r.leader(), r.Term)
log.Printf("raft.node: %x elected leader %x at term %d", r.id, r.lead, r.Term)
} else {
log.Printf("raft.node: %x changed leader from %x to %x at term %d", r.id, lead, r.leader(), r.Term)
log.Printf("raft.node: %x changed leader from %x to %x at term %d", r.id, lead, r.lead, r.Term)
}
propc = n.propc
} else {
log.Printf("raft.node: %x lost leader %x at term %d", r.id, lead, r.Term)
propc = nil
}
lead = r.leader()
lead = r.lead
}
select {

6
raft/raft.go
View File

@ -52,10 +52,6 @@ func (st StateType) String() string {
return stmap[uint64(st)]
}
func (st StateType) MarshalJSON() ([]byte, error) {
return []byte(fmt.Sprintf("%q", st.String())), nil
}
type progress struct {
match, next uint64
wait int
@ -190,8 +186,6 @@ func newRaft(id uint64, peers []uint64, election, heartbeat int, storage Storage
func (r *raft) hasLeader() bool { return r.lead != None }
func (r *raft) leader() uint64 { return r.lead }
func (r *raft) softState() *SoftState { return &SoftState{Lead: r.lead, RaftState: r.state} }
func (r *raft) q() int { return len(r.prs)/2 + 1 }

4
raft/util.go
View File

@ -23,6 +23,10 @@ import (
pb "github.com/coreos/etcd/raft/raftpb"
)
func (st StateType) MarshalJSON() ([]byte, error) {
return []byte(fmt.Sprintf("%q", st.String())), nil
}
// uint64Slice implements sort interface
type uint64Slice []uint64