aboutsummaryrefslogtreecommitdiffstats
path: root/core/transaction_pool.go
diff options
context:
space:
mode:
Diffstat (limited to 'core/transaction_pool.go')
-rw-r--r--core/transaction_pool.go19
1 files changed, 19 insertions, 0 deletions
diff --git a/core/transaction_pool.go b/core/transaction_pool.go
index 8f917e96a..ce6fed1a9 100644
--- a/core/transaction_pool.go
+++ b/core/transaction_pool.go
@@ -28,6 +28,10 @@ var (
ErrNegativeValue = errors.New("Negative value")
)
+const (
+ maxQueued = 200 // max limit of queued txs per address
+)
+
type stateFn func() *state.StateDB
// TxPool contains all currently known transactions. Transactions
@@ -224,6 +228,21 @@ func (self *TxPool) queueTx(hash common.Hash, tx *types.Transaction) {
self.queue[from] = make(map[common.Hash]*types.Transaction)
}
self.queue[from][hash] = tx
+
+ if len(self.queue[from]) > maxQueued {
+ var (
+ worstHash common.Hash
+ worstNonce uint64
+ )
+ for hash, tx := range self.queue[from] {
+ if tx.Nonce() > worstNonce {
+ worstNonce = tx.Nonce()
+ worstHash = hash
+ }
+ }
+ glog.V(logger.Debug).Infof("Queued tx limit exceeded for %x. Removed worst nonce tx: %x\n", common.PP(from[:]), common.PP(worstHash[:]))
+ delete(self.queue[from], worstHash)
+ }
}
// addTx will add a transaction to the pending (processable queue) list of transactions