diff options
author | Péter Szilágyi <peterke@gmail.com> | 2015-08-19 20:14:26 +0800 |
---|---|---|
committer | Péter Szilágyi <peterke@gmail.com> | 2015-08-19 20:14:26 +0800 |
commit | 941920f2aa651abc6bd72deda09f62d77aeaa2bf (patch) | |
tree | f5205255cab1079d0b39094cd807e220eb25db47 /eth/handler.go | |
parent | 3b997c3e169dc3dee8f41d9ece5341ef04d7eeaf (diff) | |
download | dexon-941920f2aa651abc6bd72deda09f62d77aeaa2bf.tar dexon-941920f2aa651abc6bd72deda09f62d77aeaa2bf.tar.gz dexon-941920f2aa651abc6bd72deda09f62d77aeaa2bf.tar.bz2 dexon-941920f2aa651abc6bd72deda09f62d77aeaa2bf.tar.lz dexon-941920f2aa651abc6bd72deda09f62d77aeaa2bf.tar.xz dexon-941920f2aa651abc6bd72deda09f62d77aeaa2bf.tar.zst dexon-941920f2aa651abc6bd72deda09f62d77aeaa2bf.zip |
eth: fix an issue with pulling and inserting blocks twice
Diffstat (limited to 'eth/handler.go')
-rw-r--r-- | eth/handler.go | 6 |
1 files changed, 4 insertions, 2 deletions
diff --git a/eth/handler.go b/eth/handler.go index 2bd369901..5d233dd96 100644 --- a/eth/handler.go +++ b/eth/handler.go @@ -413,10 +413,12 @@ func (pm *ProtocolManager) handleMsg(p *peer) error { pm.fetcher.Enqueue(p.id, request.Block) - // TODO: Schedule a sync to cover potential gaps (this needs proto update) + // Update the peers total difficulty if needed, schedule a download if gapped if request.TD.Cmp(p.Td()) > 0 { p.SetTd(request.TD) - go pm.synchronise(p) + if request.TD.Cmp(new(big.Int).Add(pm.chainman.Td(), request.Block.Difficulty())) > 0 { + go pm.synchronise(p) + } } case TxMsg: |