Merge pull request #1142 from obscuren/100-pct-block-prop
eth: 100% block propogation
This commit is contained in:
commit
b25e8b7079
@ -2,7 +2,6 @@ package eth
|
|||||||
|
|
||||||
import (
|
import (
|
||||||
"fmt"
|
"fmt"
|
||||||
"math"
|
|
||||||
"math/big"
|
"math/big"
|
||||||
"sync"
|
"sync"
|
||||||
"time"
|
"time"
|
||||||
@ -359,7 +358,7 @@ func (pm *ProtocolManager) verifyTd(peer *peer, request newBlockMsgData) error {
|
|||||||
func (pm *ProtocolManager) BroadcastBlock(hash common.Hash, block *types.Block) {
|
func (pm *ProtocolManager) BroadcastBlock(hash common.Hash, block *types.Block) {
|
||||||
// Broadcast block to a batch of peers not knowing about it
|
// Broadcast block to a batch of peers not knowing about it
|
||||||
peers := pm.peers.PeersWithoutBlock(hash)
|
peers := pm.peers.PeersWithoutBlock(hash)
|
||||||
peers = peers[:int(math.Sqrt(float64(len(peers))))]
|
//peers = peers[:int(math.Sqrt(float64(len(peers))))]
|
||||||
for _, peer := range peers {
|
for _, peer := range peers {
|
||||||
peer.sendNewBlock(block)
|
peer.sendNewBlock(block)
|
||||||
}
|
}
|
||||||
|
Loading…
Reference in New Issue
Block a user