forks/go-ethereum
1
0
Fork 1
mirror of https://github.com/ethereum/go-ethereum.git synced 2026-08-12 06:53:46 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 1

pos-845: efficient ticker

Browse source
This commit is contained in:
Raneet Debnath 2022-11-09 21:25:30 +05:30
parent 82bf6d0c37
commit 41fddd6a5e
1 changed files with 4 additions and 12 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

16
tests/bor/bor_reorg_test.go
View file

@ -195,9 +195,7 @@ func TestForkWithBlockTime(t *testing.T) {
genesis := initGenesis(t) genesis := initGenesis(t)
for _, test := range cases { for _, test := range cases {
test := test
t.Run(test.name, func(t *testing.T) { t.Run(test.name, func(t *testing.T) {
t.Parallel()
genesis.Config.Bor.Sprint = test.sprint genesis.Config.Bor.Sprint = test.sprint
genesis.Config.Bor.Period = test.blockTime genesis.Config.Bor.Period = test.blockTime
@ -229,15 +227,10 @@ func TestForkWithBlockTime(t *testing.T) {
go func(i int) { go func(i int) {
defer wg.Done() defer wg.Done()
for { for range ticker.C {
select { blockHeaders[i] = nodes[i].BlockChain().GetHeaderByNumber(test.sprint*test.change + 10)
case <-ticker.C: if blockHeaders[i] != nil {
blockHeaders[i] = nodes[i].BlockChain().GetHeaderByNumber(test.sprint*test.change + 10) break
if blockHeaders[i] != nil {
return
}
default:
} }
} }
@ -245,7 +238,6 @@ func TestForkWithBlockTime(t *testing.T) {
} }
wg.Wait() wg.Wait()
ticker.Stop()
// Before the end of sprint // Before the end of sprint
blockHeaderVal0 := nodes[0].BlockChain().GetHeaderByNumber(test.sprint - 1) blockHeaderVal0 := nodes[0].BlockChain().GetHeaderByNumber(test.sprint - 1)