From a9ca080d7fb8d9a0694bd06d22b23c2c85b0f25d Mon Sep 17 00:00:00 2001 From: cui Date: Wed, 22 Jul 2026 19:20:43 +0800 Subject: [PATCH] eth/fetcher: count unique hashes in blob queueing metric (#35393) blobFetcherQueueingHashes used len(announces), which is the number of peers with pending announces, not the number of queued hashes. Count unique hashes across peers instead. --------- Co-authored-by: Bosul Mun --- eth/fetcher/blob_fetcher.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/eth/fetcher/blob_fetcher.go b/eth/fetcher/blob_fetcher.go index 8a97e1c567..0b3bf7d056 100644 --- a/eth/fetcher/blob_fetcher.go +++ b/eth/fetcher/blob_fetcher.go @@ -666,7 +666,7 @@ func (f *BlobFetcher) loop() { blobFetcherWaitingPeers.Update(int64(len(f.waitslots))) blobFetcherWaitingHashes.Update(int64(len(f.waitlist))) blobFetcherQueueingPeers.Update(int64(len(f.announces) - len(f.requests))) - blobFetcherQueueingHashes.Update(int64(len(f.announces))) + blobFetcherQueueingHashes.Update(int64(len(f.full) + len(f.partial) - len(f.fetches) - len(f.waitlist))) blobFetcherFetchingPeers.Update(int64(len(f.requests))) blobFetcherFetchingHashes.Update(int64(len(f.fetches)))