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) {
36
36
newBlock.block.header.number > peerInfo.maxBlockNumber ||
37
37
newBlock.chainWeight > peerInfo.chainWeight
38
38
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 =>
44
41
val message : MessageSerializable =
45
42
if (peers(peer).remoteStatus.protocolVersion == ProtocolVersions .PV64 ) blockToBroadcast.as64
46
43
else blockToBroadcast.as63
47
44
etcPeerManager ! EtcPeerManagerActor .SendMessage (message, peer.id)
48
45
}
49
- }
50
46
51
47
private def broadcastNewBlockHash (blockToBroadcast : BlockToBroadcast , peers : Set [Peer ]): Unit = peers.foreach {
52
48
peer =>
Original file line number Diff line number Diff line change @@ -247,7 +247,7 @@ class BlockImporter(
247
247
informFetcherOnFail : Boolean ,
248
248
internally : Boolean
249
249
): 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)
251
251
importWith(
252
252
{
253
253
Task (doLog(importMessages.preImport()))
You can’t perform that action at this time.
0 commit comments