app/priority_nonce.go

@@ -14,8 +14,6 @@ import (
 	evmtypes "github.com/evmos/ethermint/x/evm/types"
 )
 
-const MAX_TXS_PRE_SENDER_IN_MEMPOOL int = 10
-
 var (
 	_ mempool.Mempool  = (*PriorityNonceMempool)(nil)
 	_ mempool.Iterator = (*PriorityNonceIterator)(nil)
@@ -36,7 +34,6 @@ type PriorityNonceMempool struct {
 	onRead         func(tx sdk.Tx)
 	txReplacement  func(op, np int64, oTx, nTx sdk.Tx) bool
 	maxTx          int
-	counterBySender map[string]int
 }
 
 type PriorityNonceIterator struct {
@@ -136,7 +133,6 @@ func NewPriorityMempool(opts ...PriorityNonceMempoolOption) *PriorityNonceMempoo
 		priorityCounts: make(map[int64]int),
 		senderIndices:  make(map[string]*skiplist.SkipList),
 		scores:         make(map[txMeta]txMeta),
-		counterBySender: make(map[string]int),
 	}
 
 	for _, opt := range opts {
@@ -208,16 +204,6 @@ func (mp *PriorityNonceMempool) Insert(ctx context.Context, tx sdk.Tx) error {
 		nonce = sig.Sequence
 	}
 
-	if _, exists := mp.counterBySender[sender]; !exists {
-		mp.counterBySender[sender] = 1
-	} else {
-		if mp.counterBySender[sender] < MAX_TXS_PRE_SENDER_IN_MEMPOOL {
-			mp.counterBySender[sender] += 1
-		} else {
-			return fmt.Errorf("tx sender has too many txs in mempool")
-		}
-	}
-
 	key := txMeta{nonce: nonce, priority: priority, sender: sender}
 
 	senderIndex, ok := mp.senderIndices[sender]
@@ -467,14 +453,6 @@ func (mp *PriorityNonceMempool) Remove(tx sdk.Tx) error {
 	delete(mp.scores, scoreKey)
 	mp.priorityCounts[score.priority]--
 
-	if _, exists := mp.counterBySender[sender]; exists {
-		if mp.counterBySender[sender] > 1 {
-			mp.counterBySender[sender] -= 1
-		} else {
-			delete(mp.counterBySender, sender)
-		}
-	}
-
 	return nil
 }