mirrors/tendermint
1
0
Fork 0
mirror of https://github.com/tendermint/tendermint.git synced 2026-02-12 23:01:30 +00:00
Code Issues Packages Projects Releases Wiki Activity

blockchain v0: lint++

Browse Source
This commit is contained in:
Aleksandr Bezobchuk
2021-01-11 14:59:03 -05:00
parent 22536ba3cf
commit a7c624eb2d
1 changed files with 9 additions and 11 deletions
Download Patch File Download Diff File Expand all files Collapse all files

20
blockchain/v0/reactor.go
View File

@@ -371,16 +371,6 @@ func (r *Reactor) SwitchToFastSync(state sm.State) error {
return nil
}
func (r *Reactor) broadcastStatusRequest() {
r.poolWG.Add(1)
defer r.poolWG.Done()
r.blockchainCh.Out() <- p2p.Envelope{
Broadcast: true,
Message: &bcproto.StatusRequest{},
}
}
func (r *Reactor) requestRoutine() {
statusUpdateTicker := time.NewTicker(statusUpdateIntervalSeconds * time.Second)
defer statusUpdateTicker.Stop()
@@ -410,7 +400,15 @@ func (r *Reactor) requestRoutine() {
}
case <-statusUpdateTicker.C:
go r.broadcastStatusRequest()
go func() {
r.poolWG.Add(1)
defer r.poolWG.Done()
r.blockchainCh.Out() <- p2p.Envelope{
Broadcast: true,
Message: &bcproto.StatusRequest{},
}
}()
}
}
}