From c9a43cf3eef079520d8ab738759a8c7784bbdac6 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 0426d5ae68..2858e16153 100644 --- a/eth/handler.go +++ b/eth/handler.go @@ -211,7 +211,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, blobBuffer) + h.txFetcher = fetcher.NewTxFetcher(h.chain, validateMeta, addTxs, fetchTx, h.removePeer, h.txTracker.NotifyAccepted, h.txTracker.NotifyRequestLatency, blobBuffer) // Construct the blob fetcher for cell-based blob data availability blobCallbacks := fetcher.BlobFetcherFunctions{