forks/go-ethereum
1
0
Fork 1
mirror of https://github.com/ethereum/go-ethereum.git synced 2026-07-17 18:30:45 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 1

core: reset txpool on sethead #26392 (#1373)

Browse source
This commit is contained in:
Daniel Liu 2025-08-22 16:45:41 +08:00 committed by GitHub
parent cf6c595dd0
commit 144fbbf35a
No known key found for this signature in database
GPG key ID: B5690EEEBB952194
1 changed files with 18 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

22
core/blockchain.go
View file

@ -436,11 +436,25 @@ func (bc *BlockChain) loadLastState() error {
return nil return nil
} }
// SetHead rewinds the local chain to a new head. In the case of headers, everything // SetHead rewinds the local chain to a new head. Depending on whether the node
// above the new head will be deleted and the new one set. In the case of blocks // was fast synced or full synced and in which state, the method will try to
// though, the head may be further rewound if block bodies are missing (non-archive // delete minimal data from disk whilst retaining chain consistency.
// nodes after a fast sync).
func (bc *BlockChain) SetHead(head uint64) error { func (bc *BlockChain) SetHead(head uint64) error {
if err := bc.setHeadBeyondRoot(head); err != nil {
return err
}
// Send chain head event to update the transaction pool
bc.chainHeadFeed.Send(ChainHeadEvent{Block: bc.CurrentBlock()})
return nil
}
// setHeadBeyondRoot rewinds the local chain to a new head with the extra condition
// that the rewind must pass the specified state root. This method is meant to be
// used when rewinding with snapshots enabled to ensure that we go back further than
// persistent disk layer. Depending on whether the node was fast synced or full, and
// in which state, the method will try to delete minimal data from disk whilst
// retaining chain consistency.
func (bc *BlockChain) setHeadBeyondRoot(head uint64) error {
if !bc.chainmu.TryLock() { if !bc.chainmu.TryLock() {
return errChainStopped return errChainStopped
} }