File tree Expand file tree Collapse file tree 2 files changed +3
-7
lines changed
src/main/scala/io/iohk/ethereum/blockchain/sync/regular Expand file tree Collapse file tree 2 files changed +3
-7
lines changed Original file line number Diff line number Diff line change @@ -36,17 +36,13 @@ class BlockBroadcast(val etcPeerManager: ActorRef) {
3636 newBlock.block.header.number > peerInfo.maxBlockNumber ||
3737 newBlock.chainWeight > peerInfo.chainWeight
3838
39- private def broadcastNewBlock (blockToBroadcast : BlockToBroadcast , peers : Map [Peer , PeerInfo ]): Unit = {
40- val peerSubset : Set [Peer ] = if (blockToBroadcast.block.hasCheckpoint) {
41- peers.keySet
42- } else obtainRandomPeerSubset(peers.keySet)
43- peerSubset.foreach { peer =>
39+ private def broadcastNewBlock (blockToBroadcast : BlockToBroadcast , peers : Map [Peer , PeerInfo ]): Unit =
40+ obtainRandomPeerSubset(peers.keySet).foreach { peer =>
4441 val message : MessageSerializable =
4542 if (peers(peer).remoteStatus.protocolVersion == ProtocolVersions .PV64 ) blockToBroadcast.as64
4643 else blockToBroadcast.as63
4744 etcPeerManager ! EtcPeerManagerActor .SendMessage (message, peer.id)
4845 }
49- }
5046
5147 private def broadcastNewBlockHash (blockToBroadcast : BlockToBroadcast , peers : Set [Peer ]): Unit = peers.foreach {
5248 peer =>
Original file line number Diff line number Diff line change @@ -247,7 +247,7 @@ class BlockImporter(
247247 informFetcherOnFail : Boolean ,
248248 internally : Boolean
249249 ): ImportFn = {
250- def doLog (entry : ImportMessages .LogEntry ): Unit = log.info(entry._2) // log.log(entry._1, entry._2)
250+ def doLog (entry : ImportMessages .LogEntry ): Unit = log.info(entry._2)// log.log(entry._1, entry._2)
251251 importWith(
252252 {
253253 Task (doLog(importMessages.preImport()))
You can’t perform that action at this time.
0 commit comments