diff options
Diffstat (limited to 'core')
| -rw-r--r-- | core/tx_pool.go | 12 |
1 files changed, 8 insertions, 4 deletions
diff --git a/core/tx_pool.go b/core/tx_pool.go index 1304f77ff..db9a6b9f9 100644 --- a/core/tx_pool.go +++ b/core/tx_pool.go @@ -296,11 +296,11 @@ func (pool *TxPool) loop() { pool.mu.Unlock() } - // Be unsubscribed due to system stopped + // Be unsubscribed due to system stopped case <-pool.chainHeadSub.Err(): return - // Handle stats reporting ticks + // Handle stats reporting ticks case <-report.C: pool.mu.RLock() pending, queued := pool.stats() @@ -312,7 +312,7 @@ func (pool *TxPool) loop() { prevPending, prevQueued, prevStales = pending, queued, stales } - // Handle inactive account transaction eviction + // Handle inactive account transaction eviction case <-evict.C: pool.mu.Lock() for addr := range pool.queue { @@ -329,7 +329,7 @@ func (pool *TxPool) loop() { } pool.mu.Unlock() - // Handle local transaction journal rotation + // Handle local transaction journal rotation case <-journal.C: if pool.journal != nil { pool.mu.Lock() @@ -1137,6 +1137,10 @@ func (pool *TxPool) demoteUnexecutables() { } } +func (pool *TxPool) ValidateTx(tx *types.Transaction, local bool) error { + return pool.validateTx(tx, local) +} + // addressByHeartbeat is an account address tagged with its last activity timestamp. type addressByHeartbeat struct { address common.Address |