diff options
| author | obscuren <geffobscura@gmail.com> | 2015-04-20 18:29:02 +0800 |
|---|---|---|
| committer | obscuren <geffobscura@gmail.com> | 2015-04-20 18:29:02 +0800 |
| commit | 45da3e17e2ada226d7c82db667d263f8e004cbfc (patch) | |
| tree | 627499fa3e24bbe70ed5c0c526d30d713205b106 /eth/handler.go | |
| parent | 52584596d4c9cee7adcc1c343addd19279aaac84 (diff) | |
| download | dexon-45da3e17e2ada226d7c82db667d263f8e004cbfc.tar.gz dexon-45da3e17e2ada226d7c82db667d263f8e004cbfc.tar.zst dexon-45da3e17e2ada226d7c82db667d263f8e004cbfc.zip | |
core: added chain head reset to known block
Diffstat (limited to 'eth/handler.go')
| -rw-r--r-- | eth/handler.go | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/eth/handler.go b/eth/handler.go index 5c0660d84..622f22132 100644 --- a/eth/handler.go +++ b/eth/handler.go @@ -36,6 +36,7 @@ pm.chainman.InsertChain(blocks) import ( "fmt" + "math" "math/big" "sync" @@ -326,7 +327,7 @@ func (pm *ProtocolManager) BroadcastBlock(hash common.Hash, block *types.Block) } // Broadcast block to peer set // XXX due to the current shit state of the network disable the limit - //peers = peers[:int(math.Sqrt(float64(len(peers))))] + peers = peers[:int(math.Sqrt(float64(len(peers))))] for _, peer := range peers { peer.sendNewBlock(block) } |