forks/go-ethereum
1
0
Fork 1
mirror of https://github.com/ethereum/go-ethereum.git synced 2026-07-22 04:36:42 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 1

core/txpool/blobpool: fix removal from gapped queue

Browse source 
Signed-off-by: Csaba Kiraly <csaba.kiraly@gmail.com>
This commit is contained in:
Csaba Kiraly 2025-09-23 12:38:45 +02:00
parent 54a69c4096
commit 6cb97cb721
No known key found for this signature in database
GPG key ID: 0FE274EE8C95166E
1 changed files with 9 additions and 9 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

18
core/txpool/blobpool/blobpool.go
View file

@ -1892,20 +1892,20 @@ func (p *BlobPool) add(tx *types.Transaction) (err error) {
if firstgap == gtxs[0].Nonce() {
// We are under lock. Add the first transaction in a goroutine to avoid blocking.
// This might lead to a race beteen new calls to add and the revalidation here,
// TODO: revisit if this is a problem, lock on gapped needed?
// TODO: revisit if this is a problem, lock on 'from' needed?
tx := gtxs[0]
p.gapped[from] = gtxs[1:]
if len(p.gapped[from]) == 0 {
delete(p.gapped, from)
}
go func() {
if err := p.add(gtxs[0]); err == nil {
// First transaction accepted, remove it from the gapped queue
p.gapped[from] = gtxs[1:]
log.Trace("Gapped blob transaction added to pool", "hash", gtxs[0].Hash(), "from", from, "nonce", gtxs[0].Nonce(), "qlen", len(p.gapped[from]))
if err := p.add(tx); err == nil {
log.Trace("Gapped blob transaction added to pool", "hash", tx.Hash(), "from", from, "nonce", tx.Nonce(), "qlen", len(p.gapped[from]))
} else {
log.Trace("Gapped blob transaction still not accepted", "hash", gtxs[0].Hash(), "from", from, "nonce", gtxs[0].Nonce(), "err", err)
log.Trace("Gapped blob transaction still not accepted", "hash", tx.Hash(), "from", from, "nonce", tx.Nonce(), "err", err)
}
}()
}
if len(p.gapped[from]) == 0 {
delete(p.gapped, from)
}
}
return nil
}