fluencelabs/tendermint
1
0
Fork 0
mirror of https://github.com/fluencelabs/tendermint synced 2025-07-04 07:01:40 +00:00
Code Issues Projects Releases Wiki Activity

return back defaultChannelCapacity

Browse Source
This commit is contained in:
Anton Kaliaev
2018-03-04 13:42:26 +04:00
parent baf457e6d4
commit f299689573
2 changed files with 7 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
blockchain/pool_test.go
View File

@ -34,8 +34,8 @@ func makePeers(numPeers int, minHeight, maxHeight int64) map[p2p.ID]testPeer {
func TestBasic(t *testing.T) { func TestBasic(t *testing.T) {
start := int64(42) start := int64(42)
peers := makePeers(10, start+1, 1000) peers := makePeers(10, start+1, 1000)
errorsCh := make(chan peerError) errorsCh := make(chan peerError, 1000)
requestsCh := make(chan BlockRequest) requestsCh := make(chan BlockRequest, 1000)
pool := NewBlockPool(start, requestsCh, errorsCh) pool := NewBlockPool(start, requestsCh, errorsCh)
pool.SetLogger(log.TestingLogger()) pool.SetLogger(log.TestingLogger())
@ -91,8 +91,8 @@ func TestBasic(t *testing.T) {
func TestTimeout(t *testing.T) { func TestTimeout(t *testing.T) {
start := int64(42) start := int64(42)
peers := makePeers(10, start+1, 1000) peers := makePeers(10, start+1, 1000)
errorsCh := make(chan peerError) errorsCh := make(chan peerError, 1000)
requestsCh := make(chan BlockRequest) requestsCh := make(chan BlockRequest, 1000)
pool := NewBlockPool(start, requestsCh, errorsCh) pool := NewBlockPool(start, requestsCh, errorsCh)
pool.SetLogger(log.TestingLogger()) pool.SetLogger(log.TestingLogger())
err := pool.Start() err := pool.Start()

5
blockchain/reactor.go
View File

@ -76,8 +76,9 @@ func NewBlockchainReactor(state sm.State, blockExec *sm.BlockExecutor, store *Bl
store.Height())) store.Height()))
} }
requestsCh := make(chan BlockRequest) const cap = 1000 // must be bigger than peers count
errorsCh := make(chan peerError) requestsCh := make(chan BlockRequest, cap)
errorsCh := make(chan peerError, cap) // so we don't block in #Receive#pool.AddBlock
pool := NewBlockPool( pool := NewBlockPool(
store.Height()+1, store.Height()+1,
requestsCh, requestsCh,