diff --git a/blocksync/pool.go b/blocksync/pool.go index 9a95fe5621..bf0788c22c 100644 --- a/blocksync/pool.go +++ b/blocksync/pool.go @@ -40,7 +40,7 @@ const ( // // Assuming a DSL connection (not a good choice) 128 Kbps (upload) ~ 15 KB/s, // sending data across atlantic ~ 7.5 KB/s. - minRecvRate = 7680 + minRecvRate = 768000 // 750 KB/s // Maximum difference between current and new block's height. maxDiffBetweenCurrentAndReceivedBlockHeight = 100 diff --git a/blocksync/reactor.go b/blocksync/reactor.go index 629fbbedc4..286ee0abbc 100644 --- a/blocksync/reactor.go +++ b/blocksync/reactor.go @@ -81,7 +81,7 @@ func NewReactorWithOfflineStateSync(state sm.State, blockExec *sm.BlockExecutor, } requestsCh := make(chan BlockRequest, maxTotalRequesters) - const capacity = 1000 // must be bigger than peers count + const capacity = 2000 // must be bigger than peers count errorsCh := make(chan peerError, capacity) // so we don't block in #Receive#pool.AddBlock appHashErrorsCh := make(chan p2p.AppHashError) // create an unbuffered channel to stream appHash errors