From 41fddd6a5edef0d2ae1c124973cac8e59f9cb6d1 Mon Sep 17 00:00:00 2001 From: Raneet Debnath Date: Wed, 9 Nov 2022 21:25:30 +0530 Subject: [PATCH] pos-845: efficient ticker --- tests/bor/bor_reorg_test.go | 16 ++++------------ 1 file changed, 4 insertions(+), 12 deletions(-) diff --git a/tests/bor/bor_reorg_test.go b/tests/bor/bor_reorg_test.go index 9615d71c1e..c759599c37 100644 --- a/tests/bor/bor_reorg_test.go +++ b/tests/bor/bor_reorg_test.go @@ -195,9 +195,7 @@ func TestForkWithBlockTime(t *testing.T) { genesis := initGenesis(t) for _, test := range cases { - test := test t.Run(test.name, func(t *testing.T) { - t.Parallel() genesis.Config.Bor.Sprint = test.sprint genesis.Config.Bor.Period = test.blockTime @@ -229,15 +227,10 @@ func TestForkWithBlockTime(t *testing.T) { go func(i int) { defer wg.Done() - for { - select { - case <-ticker.C: - blockHeaders[i] = nodes[i].BlockChain().GetHeaderByNumber(test.sprint*test.change + 10) - if blockHeaders[i] != nil { - return - } - default: - + for range ticker.C { + blockHeaders[i] = nodes[i].BlockChain().GetHeaderByNumber(test.sprint*test.change + 10) + if blockHeaders[i] != nil { + break } } @@ -245,7 +238,6 @@ func TestForkWithBlockTime(t *testing.T) { } wg.Wait() - ticker.Stop() // Before the end of sprint blockHeaderVal0 := nodes[0].BlockChain().GetHeaderByNumber(test.sprint - 1)