|
|
@ -189,18 +189,13 @@ func (pm *ProtocolManager) synchronise(peer *peer) { |
|
|
|
mode = downloader.FastSync |
|
|
|
mode = downloader.FastSync |
|
|
|
} |
|
|
|
} |
|
|
|
// Run the sync cycle, and disable fast sync if we've went past the pivot block
|
|
|
|
// Run the sync cycle, and disable fast sync if we've went past the pivot block
|
|
|
|
err := pm.downloader.Synchronise(peer.id, pHead, pTd, mode) |
|
|
|
if err := pm.downloader.Synchronise(peer.id, pHead, pTd, mode); err != nil { |
|
|
|
|
|
|
|
return |
|
|
|
|
|
|
|
} |
|
|
|
if atomic.LoadUint32(&pm.fastSync) == 1 { |
|
|
|
if atomic.LoadUint32(&pm.fastSync) == 1 { |
|
|
|
// Disable fast sync if we indeed have something in our chain
|
|
|
|
|
|
|
|
if pm.blockchain.CurrentBlock().NumberU64() > 0 { |
|
|
|
|
|
|
|
log.Info("Fast sync complete, auto disabling") |
|
|
|
log.Info("Fast sync complete, auto disabling") |
|
|
|
atomic.StoreUint32(&pm.fastSync, 0) |
|
|
|
atomic.StoreUint32(&pm.fastSync, 0) |
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
if err != nil { |
|
|
|
|
|
|
|
return |
|
|
|
|
|
|
|
} |
|
|
|
|
|
|
|
atomic.StoreUint32(&pm.acceptTxs, 1) // Mark initial sync done
|
|
|
|
atomic.StoreUint32(&pm.acceptTxs, 1) // Mark initial sync done
|
|
|
|
if head := pm.blockchain.CurrentBlock(); head.NumberU64() > 0 { |
|
|
|
if head := pm.blockchain.CurrentBlock(); head.NumberU64() > 0 { |
|
|
|
// We've completed a sync cycle, notify all peers of new state. This path is
|
|
|
|
// We've completed a sync cycle, notify all peers of new state. This path is
|
|
|
|