fluencelabs/tendermint
1
0
Fork 0
mirror of https://github.com/fluencelabs/tendermint synced 2025-06-25 02:31:46 +00:00
Code Issues Projects Releases Wiki Activity

revert back curRate != 0

Browse Source
This commit is contained in:
Anton Kaliaev
2018-02-09 13:02:44 +04:00
parent c8990d06d9
commit 0c1b91b762
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
blockchain/pool.go
View File

@ -126,8 +126,8 @@ func (pool *BlockPool) removeTimedoutPeers() {
for _, peer := range pool.peers { for _, peer := range pool.peers {
if !peer.didTimeout && peer.numPending > 0 { if !peer.didTimeout && peer.numPending > 0 {
curRate := peer.recvMonitor.Status().CurRate curRate := peer.recvMonitor.Status().CurRate
// XXX remove curRate != 0 // curRate can be 0 on start
if curRate < minRecvRate { if curRate != 0 && curRate < minRecvRate {
pool.sendTimeout(peer.id) pool.sendTimeout(peer.id)
pool.Logger.Error("SendTimeout", "peer", peer.id, pool.Logger.Error("SendTimeout", "peer", peer.id,
"reason", "peer is not sending us data fast enough", "reason", "peer is not sending us data fast enough",