Skip to content

Commit

Permalink
handle raft instance crash better
Browse files Browse the repository at this point in the history
  • Loading branch information
Nan Lin committed Mar 11, 2019
1 parent 53de46e commit 3ea8ed4
Showing 1 changed file with 0 additions and 3 deletions.
3 changes: 0 additions & 3 deletions raft/raft.go
Original file line number Diff line number Diff line change
Expand Up @@ -318,7 +318,6 @@ func (r *Raft) Input(data LogData) (term Term, index LogIndex) {
func (r *Raft) routine() {
ticker := time.NewTicker(time.Millisecond * 10)
defer ticker.Stop()
log.Printf("%s start running ...", r)

forloop:
for {
Expand Down Expand Up @@ -352,8 +351,6 @@ forloop:
break forloop
}
}

log.Printf("%s is shutdown", r)
}

func (r *Raft) handleMsg(senderID int, _msg RPCMessage) {
Expand Down

0 comments on commit 3ea8ed4

Please sign in to comment.