forks/go-ethereum
1
0
Fork 1
mirror of https://github.com/ethereum/go-ethereum.git synced 2026-07-23 05:06:43 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 1

Refactor updateFilterMapsHeads to Use Timer Instead of time.After

Browse source
This commit is contained in:
lukema95 2025-10-13 20:21:28 +08:00
parent 5c6ba6b400
commit 22deabb725
No known key found for this signature in database
1 changed files with 7 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

8
eth/backend.go
View file

@ -502,14 +502,20 @@ func (s *Ethereum) updateFilterMapsHeads() {
} }
setHead(s.blockchain.CurrentBlock()) setHead(s.blockchain.CurrentBlock())
timer := time.NewTimer(time.Second * 10)
defer timer.Stop()
for { for {
select { select {
case ev := <-headEventCh: case ev := <-headEventCh:
setHead(ev.Header) setHead(ev.Header)
timer.Reset(time.Second * 10)
case blockProc := <-blockProcCh: case blockProc := <-blockProcCh:
s.filterMaps.SetBlockProcessing(blockProc) s.filterMaps.SetBlockProcessing(blockProc)
case <-time.After(time.Second * 10): timer.Reset(time.Second * 10)
case <-timer.C:
setHead(s.blockchain.CurrentBlock()) setHead(s.blockchain.CurrentBlock())
timer.Reset(time.Second * 10)
case ch := <-s.closeFilterMaps: case ch := <-s.closeFilterMaps:
close(ch) close(ch)
return return