diff --git a/core/txpool/txpool.go b/core/txpool/txpool.go index b107b08eaf..c5f7718057 100644 --- a/core/txpool/txpool.go +++ b/core/txpool/txpool.go @@ -556,6 +556,8 @@ func (p *TxPool) Sync() error { // Clear removes all tracked txs from the subpools. func (p *TxPool) Clear() { + // Invoke Sync to ensure that txs pending addition don't get added to the pool after + // the subpools are subsequently cleared p.Sync() for _, subpool := range p.subpools { subpool.Clear()