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

eth/downloader: spell sync mode with -

Browse source
This commit is contained in:
Felix Lange 2025-12-08 19:39:12 +01:00
parent 1067523e78
commit 8529acce90
1 changed files with 7 additions and 7 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

14
eth/downloader/syncmode.go
View file

@ -48,22 +48,22 @@ func newSyncModer(mode ethconfig.SyncMode, chain BlockChain, disk ethdb.KeyValue
fullBlock, snapBlock := chain.CurrentBlock(), chain.CurrentSnapBlock() fullBlock, snapBlock := chain.CurrentBlock(), chain.CurrentSnapBlock()
if fullBlock.Number.Uint64() == 0 && snapBlock.Number.Uint64() > 0 { if fullBlock.Number.Uint64() == 0 && snapBlock.Number.Uint64() > 0 {
mode = ethconfig.SnapSync mode = ethconfig.SnapSync
log.Warn("Switch sync mode from full sync to snap sync", "reason", "snap sync incomplete") log.Warn("Switching from full-sync to snap-sync", "reason", "snap-sync incomplete")
} else if !chain.HasState(fullBlock.Root) { } else if !chain.HasState(fullBlock.Root) {
mode = ethconfig.SnapSync mode = ethconfig.SnapSync
log.Warn("Switch sync mode from full sync to snap sync", "reason", "head state missing") log.Warn("Switching from full-sync to snap-sync", "reason", "head state missing")
} else { } else {
// Grant the full sync mode // Grant the full sync mode
log.Info("Enabled full sync", "head", fullBlock.Number, "hash", fullBlock.Hash()) log.Info("Enabled full-sync", "head", fullBlock.Number, "hash", fullBlock.Hash())
} }
} else { } else {
head := chain.CurrentBlock() head := chain.CurrentBlock()
if head.Number.Uint64() > 0 && chain.HasState(head.Root) { if head.Number.Uint64() > 0 && chain.HasState(head.Root) {
mode = ethconfig.FullSync mode = ethconfig.FullSync
log.Info("Switch sync mode from snap sync to full sync", "reason", "snap sync complete") log.Info("Switching from snap-sync to full-sync", "reason", "snap-sync complete")
} else { } else {
// If snap sync was requested and our database is empty, grant it // If snap sync was requested and our database is empty, grant it
log.Info("Enabled snap sync", "head", head.Number, "hash", head.Hash()) log.Info("Enabled snap-sync", "head", head.Number, "hash", head.Hash())
} }
} }
return &moder{ return &moder{
@ -88,7 +88,7 @@ func (m *moder) getMode() ethconfig.SyncMode {
head := m.chain.CurrentBlock() head := m.chain.CurrentBlock()
if pivot := rawdb.ReadLastPivotNumber(m.disk); pivot != nil { if pivot := rawdb.ReadLastPivotNumber(m.disk); pivot != nil {
if head.Number.Uint64() < *pivot { if head.Number.Uint64() < *pivot {
log.Info("Reenabled snap sync as chain is lagging behind the pivot", "head", head.Number, "pivot", pivot) log.Info("Reenabled snap-sync as chain is lagging behind the pivot", "head", head.Number, "pivot", pivot)
return ethconfig.SnapSync return ethconfig.SnapSync
} }
} }
@ -96,7 +96,7 @@ func (m *moder) getMode() ethconfig.SyncMode {
// the head state, forcefully rerun the snap sync. Note it doesn't mean the // the head state, forcefully rerun the snap sync. Note it doesn't mean the
// persistent state is corrupted, just mismatch with the head block. // persistent state is corrupted, just mismatch with the head block.
if !m.chain.HasState(head.Root) { if !m.chain.HasState(head.Root) {
log.Info("Reenabled snap sync as chain is stateless") log.Info("Reenabled snap-sync as chain is stateless")
return ethconfig.SnapSync return ethconfig.SnapSync
} }
// Nope, we're really full syncing // Nope, we're really full syncing