forks/go-ethereum
1
0
Fork 1
mirror of https://github.com/ethereum/go-ethereum.git synced 2026-07-27 23:26:44 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 3

added a maxTxArrivalWait constant to the fetcher. config params with longer durations than maxTxArrivalWait will default to the maxTxArrivalWait duration

Browse source
This commit is contained in:
Alex 2023-04-04 23:20:07 -07:00
parent 070b13efbd
commit a5b49c313f
1 changed files with 9 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

9
eth/fetcher/tx_fetcher.go
View file

@ -56,6 +56,10 @@ const (
// txGatherSlack is the interval used to collate almost-expired announces // txGatherSlack is the interval used to collate almost-expired announces
// with network fetches. // with network fetches.
txGatherSlack = 20 * time.Millisecond txGatherSlack = 20 * time.Millisecond
// maxTxArrivalWait is the longest acceptable duration for the txArrivalWait
// configuration value. Longer config values will default to this.
maxTxArrivalWait = 500 * time.Millisecond
) )
var ( var (
@ -337,6 +341,11 @@ func (f *TxFetcher) Start() {
f.txArrivalWait = txGatherSlack f.txArrivalWait = txGatherSlack
} }
// the txArrivalWait duration should not be greater than the maxTxArrivalWait duration
if f.txArrivalWait > maxTxArrivalWait {
f.txArrivalWait = maxTxArrivalWait
}
go f.loop() go f.loop()
} }