mirror/erigon-pulse
1
0
Fork 0
mirror of https://gitlab.com/pulsechaincom/erigon-pulse.git synced 2024-12-31 16:21:21 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

consensus/ethash: fix flaky test by reading seal results (#21085)

Browse Source 
# Conflicts:
#	consensus/ethash/sealer_test.go
This commit is contained in:
meowsbits 2020-05-25 11:01:03 -05:00 committed by Igor Mandrigin
parent 5d436e6afd
commit a3520d5a67
1 changed files with 7 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
consensus/ethash/sealer_test.go
View File

@ -56,7 +56,6 @@ func TestRemoteNotify(t *testing.T) {
block := types.NewBlockWithHeader(header)
_ = ethash.Seal(consensus.NewCancel(), nil, block, nil, nil)
select {
case work := <-sink:
if want := ethash.SealHash(header).Hex(); work[0] != want {
@ -97,16 +96,22 @@ func TestRemoteMultiNotify(t *testing.T) {
ethash := NewTester([]string{server.URL}, false)
defer ethash.Close()
// Provide a results reader.
// Otherwise the unread results will be logged asynchronously
// and this can happen after the test is finished, causing a panic.
results := make(chan *types.Block, cap(sink))
// Stream a lot of work task and ensure all the notifications bubble out.
for i := 0; i < cap(sink); i++ {
header := &types.Header{Number: big.NewInt(int64(i)), Difficulty: big.NewInt(100)}
block := types.NewBlockWithHeader(header)
_ = ethash.Seal(consensus.NewCancel(), nil, block, nil, nil)
_ = ethash.Seal(consensus.NewCancel(), nil, block, results, nil)
}
for i := 0; i < cap(sink); i++ {
select {
case <-sink:
<-results
case <-time.After(10 * time.Second):
t.Fatalf("notification %d timed out", i)
}