mirrors/tendermint
1
0
Fork 0
mirror of https://github.com/tendermint/tendermint.git synced 2026-05-30 19:06:21 +00:00
Code Issues Packages Projects Releases Wiki Activity

blockchain v0: refactor BroadcastStatusRequest

Browse Source
This commit is contained in:
Aleksandr Bezobchuk
2021-01-04 16:36:34 -05:00
parent bbf126a79d
commit c978c8f4ee
1 changed files with 8 additions and 12 deletions
Download Patch File Download Diff File Expand all files Collapse all files

20
blockchain/v0/reactor.go
View File

@@ -349,6 +349,14 @@ func (r *Reactor) processPeerUpdates() {
}
}
// BroadcastStatusRequest broadcasts a StatusRequest envelope.
func (r *Reactor) BroadcastStatusRequest() {
r.blockchainCh.Out() <- p2p.Envelope{
Broadcast: true,
Message: &bcproto.StatusRequest{},
}
}
// ============================================================================
// ============================================================================
// ============================================================================
@@ -552,15 +560,3 @@ FOR_LOOP:
}
}
}
// BroadcastStatusRequest broadcasts `BlockStore` base and height.
func (bcR *BlockchainReactor) BroadcastStatusRequest() {
bm, err := bc.EncodeMsg(&bcproto.StatusRequest{})
if err != nil {
bcR.Logger.Error("could not convert StatusRequest to proto", "err", err)
return
}
// We don't care about whenever broadcast is successful or not.
_ = bcR.Switch.Broadcast(BlockchainChannel, bm)
}