forks/go-ethereum
1
0
Fork 1
mirror of https://github.com/ethereum/go-ethereum.git synced 2026-08-18 01:43:47 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 1

eth/gasprice: ensure goroutine that that purges cache upon reorg doesn't hang after dependent subscription is closed

Browse source
This commit is contained in:
Jared Wasinger 2025-01-14 14:32:29 +08:00
parent 864e717b56
commit 0510fc8662
1 changed files with 10 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

9
eth/gasprice/gasprice.go
View file

@ -120,14 +120,19 @@ func NewOracle(backend OracleBackend, params Config, startPrice *big.Int) *Oracl
cache := lru.NewCache[cacheKey, processedFees](2048) cache := lru.NewCache[cacheKey, processedFees](2048)
headEvent := make(chan core.ChainHeadEvent, 1) headEvent := make(chan core.ChainHeadEvent, 1)
backend.SubscribeChainHeadEvent(headEvent) sub := backend.SubscribeChainHeadEvent(headEvent)
go func() { go func() {
var lastHead common.Hash var lastHead common.Hash
for ev := range headEvent { for {
select {
case ev := <-headEvent:
if ev.Header.ParentHash != lastHead { if ev.Header.ParentHash != lastHead {
cache.Purge() cache.Purge()
} }
lastHead = ev.Header.Hash() lastHead = ev.Header.Hash()
case <-sub.Err():
return
}
} }
}() }()