mirror/erigon-pulse
1
0
Fork 0
mirror of https://gitlab.com/pulsechaincom/erigon-pulse.git synced 2024-12-29 07:07:16 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

[txpool] Prevent clogging up the pending sub pool (#494)

Browse Source 
* Debug txpool Best

* Print Best result

* Print

* Trace removeMined

* Remove mined tx from pending subpool

* Remove debug

Co-authored-by: Alexey Sharp <alexeysharp@Alexeys-iMac.local>
This commit is contained in:
ledgerwatch 2022-06-17 15:46:01 +01:00 committed by GitHub
parent df49481ddc
commit d7693ce094
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 4 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
txpool/pool.go
View File

@ -613,15 +613,17 @@ func (p *TxPool) Best(n uint16, txs *types.TxsRlp, tx kv.Tx) error {
best := p.pending.best best := p.pending.best
j := 0 j := 0
for i := 0; j < int(n) && i < len(best.ms); i++ { for i := 0; j < int(n) && i < len(best.ms); i++ {
if best.ms[i].Tx.Gas >= p.blockGasLimit.Load() { mt := best.ms[i]
if mt.Tx.Gas >= p.blockGasLimit.Load() {
// Skip transactions with very large gas limit // Skip transactions with very large gas limit
continue continue
} }
rlpTx, sender, isLocal, err := p.getRlpLocked(tx, best.ms[i].Tx.IDHash[:]) rlpTx, sender, isLocal, err := p.getRlpLocked(tx, mt.Tx.IDHash[:])
if err != nil { if err != nil {
return err return err
} }
if len(rlpTx) == 0 { if len(rlpTx) == 0 {
p.pending.Remove(mt)
continue continue
} }
txs.Txs[j] = rlpTx txs.Txs[j] = rlpTx