core/txpool: terminate subpool reset goroutine if pool was closed

This commit is contained in:
Jared Wasinger 2025-01-14 23:24:36 +08:00
parent 04a336aee8
commit c10ab5cf27

View file

@ -224,7 +224,12 @@ func (p *TxPool) loop(head *types.Header, chain BlockChain) {
for _, subpool := range p.subpools {
subpool.Reset(oldHead, newHead)
}
resetDone <- newHead
select {
case resetDone <- newHead:
break
case <-p.term:
return
}
}(oldHead, newHead)
// If the reset operation was explicitly requested, consider it