bump(goraft/raft): 585c58026c

This commit is contained in:
Yicheng Qin
2014-04-04 17:10:18 -07:00
parent e650329eac
commit ef98f6051c
3 changed files with 74 additions and 23 deletions

View File

@ -88,7 +88,12 @@ func (p *Peer) setLastActivity(now time.Time) {
func (p *Peer) startHeartbeat() {
p.stopChan = make(chan bool)
c := make(chan bool)
go p.heartbeat(c)
p.server.routineGroup.Add(1)
go func() {
defer p.server.routineGroup.Done()
p.heartbeat(c)
}()
<-c
}