Browse Source

Make pool tests faster

pull/43/merge
Jae Kwon 10 years ago
parent
commit
a4606f1c5e
2 changed files with 9 additions and 1 deletions
  1. +4
    -1
      blockchain/pool.go
  2. +5
    -0
      blockchain/pool_test.go

+ 4
- 1
blockchain/pool.go View File

@ -12,7 +12,6 @@ import (
const ( const (
maxOutstandingRequestsPerPeer = 10 maxOutstandingRequestsPerPeer = 10
eventsChannelCapacity = 100 eventsChannelCapacity = 100
requestTimeoutSeconds = 10
maxTries = 3 maxTries = 3
requestIntervalMS = 500 requestIntervalMS = 500
requestBatchSize = 50 requestBatchSize = 50
@ -21,6 +20,10 @@ const (
maxPeersPerRequest = 1 maxPeersPerRequest = 1
) )
var (
requestTimeoutSeconds = time.Duration(10)
)
type BlockRequest struct { type BlockRequest struct {
Height uint Height uint
PeerId string PeerId string


+ 5
- 0
blockchain/pool_test.go View File

@ -3,6 +3,7 @@ package blockchain
import ( import (
"math/rand" "math/rand"
"testing" "testing"
"time"
. "github.com/tendermint/tendermint/common" . "github.com/tendermint/tendermint/common"
"github.com/tendermint/tendermint/types" "github.com/tendermint/tendermint/types"
@ -74,6 +75,10 @@ func TestBasic(t *testing.T) {
} }
func TestTimeout(t *testing.T) { func TestTimeout(t *testing.T) {
origRequestTimeoutSeconds := requestTimeoutSeconds
requestTimeoutSeconds = time.Duration(0)
defer func() { requestTimeoutSeconds = origRequestTimeoutSeconds }()
peers := makePeers(100, 0, 1000) peers := makePeers(100, 0, 1000)
start := uint(42) start := uint(42)
timeoutsCh := make(chan string, 10) timeoutsCh := make(chan string, 10)


Loading…
Cancel
Save