|
|
@ -1459,7 +1459,7 @@ func (pool *TxPool) truncatePending() { |
|
|
|
pendingRateLimitMeter.Mark(int64(pendingBeforeCap - pending)) |
|
|
|
pendingRateLimitMeter.Mark(int64(pendingBeforeCap - pending)) |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
// truncateQueue drops the oldes transactions in the queue if the pool is above the global queue limit.
|
|
|
|
// truncateQueue drops the oldest transactions in the queue if the pool is above the global queue limit.
|
|
|
|
func (pool *TxPool) truncateQueue() { |
|
|
|
func (pool *TxPool) truncateQueue() { |
|
|
|
queued := uint64(0) |
|
|
|
queued := uint64(0) |
|
|
|
for _, list := range pool.queue { |
|
|
|
for _, list := range pool.queue { |
|
|
|