cerc-io/lotus
16
0
Fork 0
Code Issues Pull Requests Packages Projects Releases 27 Wiki Activity

fixed unit tests

Browse Source
This commit is contained in:
Alfonso de la Rocha 2022-09-16 09:22:37 +02:00
parent d1a4f1dc50
commit 72c80a3461
No known key found for this signature in database
GPG Key ID: 97DE48FDFC756FBD
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
chain/sub/bcast/consistent_test.go
View File

@ -19,7 +19,7 @@ import (
"github.com/stretchr/testify/require" "github.com/stretchr/testify/require"
) )
const TEST_DELAY = 1 const TEST_DELAY = 1 * time.Second
func TestSimpleDelivery(t *testing.T) { func TestSimpleDelivery(t *testing.T) {
cb := bcast.NewConsistentBCast(TEST_DELAY) cb := bcast.NewConsistentBCast(TEST_DELAY)
@ -27,7 +27,7 @@ func TestSimpleDelivery(t *testing.T) {
start := time.Now() start := time.Now()
testSimpleDelivery(t, cb, 100, 5) testSimpleDelivery(t, cb, 100, 5)
since := time.Since(start) since := time.Since(start)
require.GreaterOrEqual(t, since, TEST_DELAY*time.Second) require.GreaterOrEqual(t, since, TEST_DELAY)
} }
func testSimpleDelivery(t *testing.T, cb *bcast.ConsistentBCast, epoch abi.ChainEpoch, numBlocks int) { func testSimpleDelivery(t *testing.T, cb *bcast.ConsistentBCast, epoch abi.ChainEpoch, numBlocks int) {
@ -67,7 +67,7 @@ func TestSeveralEpochs(t *testing.T) {
defer wg.Done() defer wg.Done()
// Add a random delay between epochs // Add a random delay between epochs
r := mrand.Intn(500) r := mrand.Intn(500)
time.Sleep(time.Duration(i*TEST_DELAY)*time.Second + time.Duration(r)*time.Millisecond) time.Sleep(time.Duration(i)*TEST_DELAY + time.Duration(r)*time.Millisecond)
rNumBlocks := mrand.Intn(5) rNumBlocks := mrand.Intn(5)
flip, err := flipCoin(0.7) flip, err := flipCoin(0.7)
require.NoError(t, err) require.NoError(t, err)
@ -169,7 +169,7 @@ func TestFailedEquivocation(t *testing.T) {
go func(i int, proof []byte) { go func(i int, proof []byte) {
defer wg.Done() defer wg.Done()
// The equivocated block arrives late // The equivocated block arrives late
time.Sleep(2 * TEST_DELAY * time.Second) time.Sleep(2 * TEST_DELAY)
// Use the same proof and the same epoch // Use the same proof and the same epoch
blk := newBlock(t, 100, proof, []byte("invalid"+strconv.Itoa(i))) blk := newBlock(t, 100, proof, []byte("invalid"+strconv.Itoa(i)))
cb.RcvBlock(ctx, blk) cb.RcvBlock(ctx, blk)