|
|
|
@ -406,7 +406,7 @@ func (pool *LegacyPool) Close() error { |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
// Reset implements txpool.SubPool, allowing the legacy pool's internal state to be
|
|
|
|
|
// kept in sync with the main transacion pool's internal state.
|
|
|
|
|
// kept in sync with the main transaction pool's internal state.
|
|
|
|
|
func (pool *LegacyPool) Reset(oldHead, newHead *types.Header) { |
|
|
|
|
wait := pool.requestReset(oldHead, newHead) |
|
|
|
|
<-wait |
|
|
|
@ -637,7 +637,7 @@ func (pool *LegacyPool) validateTx(tx *types.Transaction, local bool) error { |
|
|
|
|
// pending or queued one, it overwrites the previous transaction if its price is higher.
|
|
|
|
|
//
|
|
|
|
|
// If a newly added transaction is marked as local, its sending account will be
|
|
|
|
|
// be added to the allowlist, preventing any associated transaction from being dropped
|
|
|
|
|
// added to the allowlist, preventing any associated transaction from being dropped
|
|
|
|
|
// out of the pool due to pricing constraints.
|
|
|
|
|
func (pool *LegacyPool) add(tx *types.Transaction, local bool) (replaced bool, err error) { |
|
|
|
|
// If the transaction is already known, discard it
|
|
|
|
@ -943,7 +943,7 @@ func (pool *LegacyPool) addRemoteSync(tx *types.Transaction) error { |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
// Add enqueues a batch of transactions into the pool if they are valid. Depending
|
|
|
|
|
// on the local flag, full pricing contraints will or will not be applied.
|
|
|
|
|
// on the local flag, full pricing constraints will or will not be applied.
|
|
|
|
|
//
|
|
|
|
|
// If sync is set, the method will block until all internal maintenance related
|
|
|
|
|
// to the add is finished. Only use this during tests for determinism!
|
|
|
|
|