From d56370b9101717d7b48c5862416a8069df949174 Mon Sep 17 00:00:00 2001 From: Alex Date: Thu, 9 Feb 2023 03:14:38 -0800 Subject: [PATCH] added check to set the txArrivalWait value to the txGatherSlack value if txArrivalWait < txGatherSlack --- eth/fetcher/tx_fetcher.go | 5 +++++ 1 file changed, 5 insertions(+) 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() }