diff --git a/eth/fetcher/tx_fetcher.go b/eth/fetcher/tx_fetcher.go index 81f28d66d3..8bdb1547e8 100644 --- a/eth/fetcher/tx_fetcher.go +++ b/eth/fetcher/tx_fetcher.go @@ -719,6 +719,7 @@ func (f *TxFetcher) rescheduleWait(timer *mclock.Timer, trigger chan struct{}) { } } } + *timer = f.clock.AfterFunc( f.txArrivalWait-time.Duration(now-earliest), func() { trigger <- struct{}{} },