forks/go-ethereum
1
0
Fork 1
mirror of https://github.com/ethereum/go-ethereum.git synced 2026-08-20 10:52:25 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 1

downloader/import: calcPastMedianTime/Flux compatibility fix

Browse source
This commit is contained in:
Luke Williams 2019-02-22 04:41:47 +01:00
parent fabeb277ae
commit 7ca02d4b07
2 changed files with 12 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
cmd/utils/cmd.go
View file

@ -35,7 +35,7 @@ import (
) )
const ( const (
importBatchSize = 2500 importBatchSize = 1
) )
// Fatalf formats a message to standard error and exits the program. // Fatalf formats a message to standard error and exits the program.

13
eth/downloader/downloader.go
View file

@ -58,8 +58,9 @@ var (
qosTuningImpact = 0.25 // Impact that a new tuning target has on the previous value qosTuningImpact = 0.25 // Impact that a new tuning target has on the previous value
maxQueuedHeaders = 32 * 1024 // [eth/62] Maximum number of headers to queue for import (DOS protection) maxQueuedHeaders = 32 * 1024 // [eth/62] Maximum number of headers to queue for import (DOS protection)
maxHeadersProcess = 2048 // Number of header download results to import at once into the chain // set maxHeadersProcess & maxResultsProcess to 1 so calcPastMedianTime/flux dont implode.
maxResultsProcess = 2048 // Number of content download results to import at once into the chain maxHeadersProcess = 1 // Number of header download results to import at once into the chain
maxResultsProcess = 1 // Number of content download results to import at once into the chain
fsHeaderCheckFrequency = 100 // Verification frequency of the downloaded headers during fast sync fsHeaderCheckFrequency = 100 // Verification frequency of the downloaded headers during fast sync
fsHeaderSafetyNet = 2048 // Number of headers to discard in case a chain violation is detected fsHeaderSafetyNet = 2048 // Number of headers to discard in case a chain violation is detected
@ -389,6 +390,14 @@ func (d *Downloader) synchronise(id string, hash common.Hash, td *big.Int, mode
if d.mode == FastSync && atomic.LoadUint32(&d.fsPivotFails) >= fsCriticalTrials { if d.mode == FastSync && atomic.LoadUint32(&d.fsPivotFails) >= fsCriticalTrials {
d.mode = FullSync d.mode = FullSync
} }
// If FastSync its safe to increase maxResultsProcess
if d.mode == FastSync {
maxResultsProcess = 2048
} else {
maxResultsProcess = 1
}
// Retrieve the origin peer and initiate the downloading process // Retrieve the origin peer and initiate the downloading process
p := d.peers.Peer(id) p := d.peers.Peer(id)
if p == nil { if p == nil {