diff --git a/eth/fetcher/tx_fetcher.go b/eth/fetcher/tx_fetcher.go index 7d85e50bd2..ad2ff13979 100644 --- a/eth/fetcher/tx_fetcher.go +++ b/eth/fetcher/tx_fetcher.go @@ -332,6 +332,11 @@ func (f *TxFetcher) Drop(peer string) error { // Start boots up the announcement based synchroniser, accepting and processing // hash notifications and block fetches until termination requested. func (f *TxFetcher) Start() { + // the txArrivalWait duration should not be less than the txGatherSlack duration + if f.txArrivalWait < txGatherSlack { + f.txArrivalWait = txGatherSlack + } + go f.loop() }