From 275020f988eb0b93875c578a9f7235397af65aac Mon Sep 17 00:00:00 2001 From: Csaba Kiraly Date: Mon, 13 Apr 2026 21:06:17 +0200 Subject: [PATCH] eth: wire txTracker.NotifyRequestLatency into tx fetcher Plugs the tx fetcher's new onRequestLatency callback into the txtracker's per-peer latency EMA. Tx-request round-trip and timeout samples now flow into Tracker state and become available to the dropper as a per-peer PeerInclusionStats.RequestLatencyEMA signal. --- eth/handler.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/eth/handler.go b/eth/handler.go index 6e6b0bb8ac..d7d02295f4 100644 --- a/eth/handler.go +++ b/eth/handler.go @@ -191,7 +191,7 @@ func newHandler(config *handlerConfig) (*handler, error) { return nil } h.txTracker = txtracker.New() - h.txFetcher = fetcher.NewTxFetcher(h.chain, validateMeta, addTxs, fetchTx, h.removePeer, h.txTracker.NotifyAccepted, nil) + h.txFetcher = fetcher.NewTxFetcher(h.chain, validateMeta, addTxs, fetchTx, h.removePeer, h.txTracker.NotifyAccepted, h.txTracker.NotifyRequestLatency) return h, nil }