added check to set the txArrivalWait value to the txGatherSlack value…

… if txArrivalWait < txGatherSlack
thogard785 · Feb 9, 2023 · d56370b · d56370b
1 parent b8be0da
commit d56370b
Showing 1 changed file with 5 additions and 0 deletions.
diff --git 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()
 }