diff --git a/core/blockchain.go b/core/blockchain.go index 408d5a4c53..d112a86fd9 100644 --- a/core/blockchain.go +++ b/core/blockchain.go @@ -1616,7 +1616,7 @@ func (bc *BlockChain) insertChain(chain types.Blocks, setHead bool, makeWitness return nil, 0, nil } // Start a parallel signature recovery (signer will fluke on fork transition, minimal perf loss) - GetSenderCacher().RecoverFromBlocks(types.MakeSigner(bc.chainConfig, chain[0].Number(), chain[0].Time()), chain) + SenderCacher().RecoverFromBlocks(types.MakeSigner(bc.chainConfig, chain[0].Number(), chain[0].Time()), chain) var ( stats = insertStats{startTime: mclock.Now()} diff --git a/core/sender_cacher.go b/core/sender_cacher.go index c6f33e315c..2c4ebf87bb 100644 --- a/core/sender_cacher.go +++ b/core/sender_cacher.go @@ -31,10 +31,10 @@ var ( senderCacherInstance = newTxSenderCacher(runtime.NumCPU()) ) -// GetSenderCacher returns the singleton instance of SenderCacher. +// SenderCacher returns the singleton instance of SenderCacher. // If the instance has not been initialized yet, it will be created using newTxSenderCacher. // This function is thread-safe and ensures that initialization happens only once. -func GetSenderCacher() *txSenderCacher { +func SenderCacher() *txSenderCacher { senderCacherOnce.Do(func() { senderCacherInstance = newTxSenderCacher(runtime.NumCPU()) }) diff --git a/core/txpool/legacypool/legacypool.go b/core/txpool/legacypool/legacypool.go index 84975f4396..55899c18fb 100644 --- a/core/txpool/legacypool/legacypool.go +++ b/core/txpool/legacypool/legacypool.go @@ -1440,7 +1440,7 @@ func (pool *LegacyPool) reset(oldHead, newHead *types.Header) { // Inject any transactions discarded due to reorgs log.Debug("Reinjecting stale transactions", "count", len(reinject)) - core.GetSenderCacher().Recover(pool.signer, reinject) + core.SenderCacher().Recover(pool.signer, reinject) pool.addTxsLocked(reinject, false) }