forked from cerc-io/plugeth
core: sanitize more TxPoolConfig fields (#17210)
* core: sanitize more TxPoolConfig fields * core: fix TestTransactionPendingMinimumAllowance
This commit is contained in:
parent
5f251a6448
commit
27ce4eb78b
@ -172,6 +172,26 @@ func (config *TxPoolConfig) sanitize() TxPoolConfig {
|
|||||||
log.Warn("Sanitizing invalid txpool price bump", "provided", conf.PriceBump, "updated", DefaultTxPoolConfig.PriceBump)
|
log.Warn("Sanitizing invalid txpool price bump", "provided", conf.PriceBump, "updated", DefaultTxPoolConfig.PriceBump)
|
||||||
conf.PriceBump = DefaultTxPoolConfig.PriceBump
|
conf.PriceBump = DefaultTxPoolConfig.PriceBump
|
||||||
}
|
}
|
||||||
|
if conf.AccountSlots < 1 {
|
||||||
|
log.Warn("Sanitizing invalid txpool account slots", "provided", conf.AccountSlots, "updated", DefaultTxPoolConfig.AccountSlots)
|
||||||
|
conf.AccountSlots = DefaultTxPoolConfig.AccountSlots
|
||||||
|
}
|
||||||
|
if conf.GlobalSlots < 1 {
|
||||||
|
log.Warn("Sanitizing invalid txpool global slots", "provided", conf.GlobalSlots, "updated", DefaultTxPoolConfig.GlobalSlots)
|
||||||
|
conf.GlobalSlots = DefaultTxPoolConfig.GlobalSlots
|
||||||
|
}
|
||||||
|
if conf.AccountQueue < 1 {
|
||||||
|
log.Warn("Sanitizing invalid txpool account queue", "provided", conf.AccountQueue, "updated", DefaultTxPoolConfig.AccountQueue)
|
||||||
|
conf.AccountQueue = DefaultTxPoolConfig.AccountQueue
|
||||||
|
}
|
||||||
|
if conf.GlobalQueue < 1 {
|
||||||
|
log.Warn("Sanitizing invalid txpool global queue", "provided", conf.GlobalQueue, "updated", DefaultTxPoolConfig.GlobalQueue)
|
||||||
|
conf.GlobalQueue = DefaultTxPoolConfig.GlobalQueue
|
||||||
|
}
|
||||||
|
if conf.Lifetime < 1 {
|
||||||
|
log.Warn("Sanitizing invalid txpool lifetime", "provided", conf.Lifetime, "updated", DefaultTxPoolConfig.Lifetime)
|
||||||
|
conf.Lifetime = DefaultTxPoolConfig.Lifetime
|
||||||
|
}
|
||||||
return conf
|
return conf
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -1095,7 +1095,7 @@ func TestTransactionPendingMinimumAllowance(t *testing.T) {
|
|||||||
blockchain := &testBlockChain{statedb, 1000000, new(event.Feed)}
|
blockchain := &testBlockChain{statedb, 1000000, new(event.Feed)}
|
||||||
|
|
||||||
config := testTxPoolConfig
|
config := testTxPoolConfig
|
||||||
config.GlobalSlots = 0
|
config.GlobalSlots = 1
|
||||||
|
|
||||||
pool := NewTxPool(config, params.TestChainConfig, blockchain)
|
pool := NewTxPool(config, params.TestChainConfig, blockchain)
|
||||||
defer pool.Stop()
|
defer pool.Stop()
|
||||||
|
Loading…
Reference in New Issue
Block a user