diff --git a/eth/fetcher/blob_fetcher.go b/eth/fetcher/blob_fetcher.go index 98d0ff24c4..d8a2f205ea 100644 --- a/eth/fetcher/blob_fetcher.go +++ b/eth/fetcher/blob_fetcher.go @@ -378,6 +378,7 @@ func (f *BlobFetcher) loop() { } delete(f.waittime, hash) delete(f.waitlist, hash) + blobAnnounceTimeoutMeter.Mark(1) } } diff --git a/eth/fetcher/metrics.go b/eth/fetcher/metrics.go index a2317e7c64..4eb4db0a99 100644 --- a/eth/fetcher/metrics.go +++ b/eth/fetcher/metrics.go @@ -60,6 +60,8 @@ var ( blobAnnounceInMeter = metrics.NewRegisteredMeter("eth/fetcher/blob/announces/in", nil) blobAnnounceDOSMeter = metrics.NewRegisteredMeter("eth/fetcher/blob/announces/dos", nil) + // This metric is to track the number of availability failure + blobAnnounceTimeoutMeter = metrics.NewRegisteredMeter("eth/fetcher/blob/announces/timeout", nil) blobRequestOutMeter = metrics.NewRegisteredMeter("eth/fetcher/blob/request/out", nil) blobRequestFailMeter = metrics.NewRegisteredMeter("eth/fetcher/blob/request/fail", nil)