From 497b96f5b78fcde9d95a138c961a47ec2284defc Mon Sep 17 00:00:00 2001 From: Csaba Kiraly Date: Wed, 3 Sep 2025 12:18:06 +0200 Subject: [PATCH] core/txpool/blobpool: handle more errors internally on getblobsv1 Signed-off-by: Csaba Kiraly --- core/txpool/blobpool/blobpool.go | 9 ++++++--- 1 file changed, 6 insertions(+), 3 deletions(-) diff --git a/core/txpool/blobpool/blobpool.go b/core/txpool/blobpool/blobpool.go index 68ea557633..612529e55e 100644 --- a/core/txpool/blobpool/blobpool.go +++ b/core/txpool/blobpool/blobpool.go @@ -1334,17 +1334,20 @@ func (p *BlobPool) GetBlobs(vhashes []common.Hash, version byte) ([]*kzg4844.Blo } data, err := p.store.Get(txID) if err != nil { - return nil, nil, nil, err + log.Error("Tracked blob transaction missing from store", "id", txID, "err", err) + continue } // Decode the blob transaction tx := new(types.Transaction) if err := rlp.DecodeBytes(data, tx); err != nil { - return nil, nil, nil, err + log.Error("Blobs corrupted for traced transaction", "id", txID, "err", err) + continue } sidecar := tx.BlobTxSidecar() if sidecar == nil { - return nil, nil, nil, fmt.Errorf("blob tx without sidecar %x", tx.Hash()) + log.Error("Blob tx without sidecar", "id", txID) + continue } // Traverse the blobs in the transaction for i, hash := range tx.BlobHashes() {