les, light: slim the unit tests

This commit is contained in:
rjl493456442 2019-11-06 16:26:58 +08:00
parent 4e7c7a8d1b
commit e09f8e8647
6 changed files with 33 additions and 23 deletions

View file

@ -110,13 +110,15 @@ func (d *requestDistributor) registerTestPeer(p distPeer) {
d.peerLock.Unlock() d.peerLock.Unlock()
} }
// distMaxWait is the maximum waiting time after which further necessary waiting var (
// times are recalculated based on new feedback from the servers // distMaxWait is the maximum waiting time after which further necessary waiting
const distMaxWait = time.Millisecond * 50 // times are recalculated based on new feedback from the servers
distMaxWait = time.Millisecond * 50
// waitForPeers is the time window in which a request does not fail even if it // waitForPeers is the time window in which a request does not fail even if it
// has no suitable peers to send to at the moment // has no suitable peers to send to at the moment
const waitForPeers = time.Second * 3 waitForPeers = time.Second * 3
)
// main event loop // main event loop
func (d *requestDistributor) loop() { func (d *requestDistributor) loop() {

View file

@ -86,8 +86,8 @@ func (p *testDistPeer) worker(t *testing.T, checkOrder bool, stop chan struct{})
const ( const (
testDistBufLimit = 10000000 testDistBufLimit = 10000000
testDistMaxCost = 1000000 testDistMaxCost = 1000000
testDistPeerCount = 5 testDistPeerCount = 2
testDistReqCount = 5000 testDistReqCount = 10
testDistMaxResendCount = 3 testDistMaxResendCount = 3
) )
@ -128,6 +128,9 @@ func testRequestDistributor(t *testing.T, resend bool) {
go peers[i].worker(t, !resend, stop) go peers[i].worker(t, !resend, stop)
dist.registerTestPeer(peers[i]) dist.registerTestPeer(peers[i])
} }
// Disable the mechanism that we will wait a few time for request
// even there is no suitable peer to send right now.
waitForPeers = 0
var wg sync.WaitGroup var wg sync.WaitGroup

View file

@ -193,6 +193,9 @@ func testOdr(t *testing.T, protocol int, expFail uint64, checkCached bool, fn od
if clientHead.Number.Uint64() != 4 { if clientHead.Number.Uint64() != 4 {
t.Fatalf("Failed to sync the chain with server, head: %v", clientHead.Number.Uint64()) t.Fatalf("Failed to sync the chain with server, head: %v", clientHead.Number.Uint64())
} }
// Disable the mechanism that we will wait a few time for request
// even there is no suitable peer to send right now.
waitForPeers = 0
test := func(expFail uint64) { test := func(expFail uint64) {
// Mark this as a helper to put the failures at the correct lines // Mark this as a helper to put the failures at the correct lines
@ -202,6 +205,8 @@ func testOdr(t *testing.T, protocol int, expFail uint64, checkCached bool, fn od
bhash := rawdb.ReadCanonicalHash(server.db, i) bhash := rawdb.ReadCanonicalHash(server.db, i)
b1 := fn(light.NoOdr, server.db, server.handler.server.chainConfig, server.handler.blockchain, nil, bhash) b1 := fn(light.NoOdr, server.db, server.handler.server.chainConfig, server.handler.blockchain, nil, bhash)
// Set the timeout as 1 second here, ensure there is enough time
// for travis to make the action.
ctx, cancel := context.WithTimeout(context.Background(), time.Second) ctx, cancel := context.WithTimeout(context.Background(), time.Second)
b2 := fn(ctx, client.db, client.handler.backend.chainConfig, nil, client.handler.backend.blockchain, bhash) b2 := fn(ctx, client.db, client.handler.backend.chainConfig, nil, client.handler.backend.blockchain, bhash)
cancel() cancel()

View file

@ -89,7 +89,7 @@ func testCheckpointSyncing(t *testing.T, protocol int, syncMode int) {
for { for {
_, hash, _, err := server.handler.server.oracle.contract.Contract().GetLatestCheckpoint(nil) _, hash, _, err := server.handler.server.oracle.contract.Contract().GetLatestCheckpoint(nil)
if err != nil || hash == [32]byte{} { if err != nil || hash == [32]byte{} {
time.Sleep(100 * time.Millisecond) time.Sleep(10 * time.Millisecond)
continue continue
} }
break break

View file

@ -71,10 +71,10 @@ var (
var ( var (
// The block frequency for creating checkpoint(only used in test) // The block frequency for creating checkpoint(only used in test)
sectionSize = big.NewInt(512) sectionSize = big.NewInt(128)
// The number of confirmations needed to generate a checkpoint(only used in test). // The number of confirmations needed to generate a checkpoint(only used in test).
processConfirms = big.NewInt(4) processConfirms = big.NewInt(1)
// The token bucket buffer limit for testing purpose. // The token bucket buffer limit for testing purpose.
testBufLimit = uint64(1000000) testBufLimit = uint64(1000000)

View file

@ -79,21 +79,21 @@ var (
} }
// TestServerIndexerConfig wraps a set of configs as a test indexer config for server side. // TestServerIndexerConfig wraps a set of configs as a test indexer config for server side.
TestServerIndexerConfig = &IndexerConfig{ TestServerIndexerConfig = &IndexerConfig{
ChtSize: 512, ChtSize: 128,
ChtConfirms: 4, ChtConfirms: 1,
BloomSize: 64, BloomSize: 16,
BloomConfirms: 4, BloomConfirms: 1,
BloomTrieSize: 512, BloomTrieSize: 128,
BloomTrieConfirms: 4, BloomTrieConfirms: 1,
} }
// TestClientIndexerConfig wraps a set of configs as a test indexer config for client side. // TestClientIndexerConfig wraps a set of configs as a test indexer config for client side.
TestClientIndexerConfig = &IndexerConfig{ TestClientIndexerConfig = &IndexerConfig{
ChtSize: 512, ChtSize: 128,
ChtConfirms: 32, ChtConfirms: 8,
BloomSize: 512, BloomSize: 128,
BloomConfirms: 32, BloomConfirms: 8,
BloomTrieSize: 512, BloomTrieSize: 128,
BloomTrieConfirms: 32, BloomTrieConfirms: 8,
} }
) )