From 6895e66b8c413748a1532f834a25165ff18509e4 Mon Sep 17 00:00:00 2001 From: Csaba Kiraly Date: Thu, 15 Jan 2026 22:11:35 +0100 Subject: [PATCH] eth/fetcher: add metric Signed-off-by: Csaba Kiraly --- eth/fetcher/metrics.go | 1 + eth/fetcher/tx_fetcher.go | 4 +++- 2 files changed, 4 insertions(+), 1 deletion(-) diff --git a/eth/fetcher/metrics.go b/eth/fetcher/metrics.go index fd1678dd30..3c0d6a8fd8 100644 --- a/eth/fetcher/metrics.go +++ b/eth/fetcher/metrics.go @@ -24,6 +24,7 @@ var ( txAnnounceInMeter = metrics.NewRegisteredMeter("eth/fetcher/transaction/announces/in", nil) txAnnounceKnownMeter = metrics.NewRegisteredMeter("eth/fetcher/transaction/announces/known", nil) txAnnounceUnderpricedMeter = metrics.NewRegisteredMeter("eth/fetcher/transaction/announces/underpriced", nil) + txAnnounceOnchainMeter = metrics.NewRegisteredMeter("eth/fetcher/transaction/announces/onchain", nil) txAnnounceDOSMeter = metrics.NewRegisteredMeter("eth/fetcher/transaction/announces/dos", nil) txBroadcastInMeter = metrics.NewRegisteredMeter("eth/fetcher/transaction/broadcasts/in", nil) diff --git a/eth/fetcher/tx_fetcher.go b/eth/fetcher/tx_fetcher.go index 3f30a73254..13d189a95f 100644 --- a/eth/fetcher/tx_fetcher.go +++ b/eth/fetcher/tx_fetcher.go @@ -246,6 +246,7 @@ func (f *TxFetcher) Notify(peer string, types []byte, sizes []uint32, hashes []c unknownMetas = make([]txMetadata, 0, len(hashes)) duplicate int64 + onchain int64 underpriced int64 ) for i, hash := range hashes { @@ -260,7 +261,7 @@ func (f *TxFetcher) Notify(peer string, types []byte, sizes []uint32, hashes []c // check on chain as well (no need to check limbo separately, as chain checks limbo too) if _, exist := f.txOnChainCache.Get(hash); exist { - duplicate++ //TODO + onchain++ continue } @@ -278,6 +279,7 @@ func (f *TxFetcher) Notify(peer string, types []byte, sizes []uint32, hashes []c } txAnnounceKnownMeter.Mark(duplicate) txAnnounceUnderpricedMeter.Mark(underpriced) + txAnnounceOnchainMeter.Mark(onchain) // If anything's left to announce, push it into the internal loop if len(unknownHashes) == 0 {