forks/go-ethereum
1
0
Fork 1
mirror of https://github.com/ethereum/go-ethereum.git synced 2026-07-22 04:36:42 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 1

Update filter_system_test.go

Browse source
This commit is contained in:
0xFloki 2025-12-15 19:31:46 +01:00 committed by GitHub
parent 6978ab48aa
commit 01e08a0bf1
No known key found for this signature in database
GPG key ID: B5690EEEBB952194
1 changed files with 10 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

13
eth/filters/filter_system_test.go
View file

@ -169,7 +169,7 @@ func (b *testBackend) NewMatcherBackend() filtermaps.MatcherBackend {
return b.fm.NewMatcherBackend() return b.fm.NewMatcherBackend()
} }
func (b *testBackend) startFilterMaps(history uint64, disabled bool, params filtermaps.Params) { func (b *testBackend) startFilterMaps(history uint64, disabled bool, params filtermaps.Params) error {
head := b.CurrentBlock() head := b.CurrentBlock()
chainView := filtermaps.NewChainView(b, head.Number.Uint64(), head.Hash()) chainView := filtermaps.NewChainView(b, head.Number.Uint64(), head.Hash())
config := filtermaps.Config{ config := filtermaps.Config{
@ -177,9 +177,14 @@ func (b *testBackend) startFilterMaps(history uint64, disabled bool, params filt
Disabled: disabled, Disabled: disabled,
ExportFileName: "", ExportFileName: "",
} }
b.fm, _ = filtermaps.NewFilterMaps(b.db, chainView, 0, 0, params, config) fm, err := filtermaps.NewFilterMaps(b.db, chainView, 0, 0, params, config)
if err != nil {
return err
}
b.fm = fm
b.fm.Start() b.fm.Start()
b.fm.WaitIdle() b.fm.WaitIdle()
return nil
} }
func (b *testBackend) stopFilterMaps() { func (b *testBackend) stopFilterMaps() {
@ -563,7 +568,9 @@ func TestExceedLogQueryLimit(t *testing.T) {
t.Fatal(err) t.Fatal(err)
} }
backend.startFilterMaps(200, false, filtermaps.RangeTestParams) if err := backend.startFilterMaps(200, false, filtermaps.RangeTestParams); err != nil {
t.Fatalf("failed to start filter maps: %v", err)
}
defer backend.stopFilterMaps() defer backend.stopFilterMaps()
addresses := make([]common.Address, 6) addresses := make([]common.Address, 6)