Skip to content

Commit b904b91

Browse files
committed
Revert "etcm-651 added sending checkpoints to all peers"
This reverts commit ba105b1.
1 parent f63d559 commit b904b91

File tree

2 files changed

+3
-7
lines changed

2 files changed

+3
-7
lines changed

src/main/scala/io/iohk/ethereum/blockchain/sync/regular/BlockBroadcast.scala

Lines changed: 2 additions & 6 deletions
Original file line numberDiff line numberDiff 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 =>

src/main/scala/io/iohk/ethereum/blockchain/sync/regular/BlockImporter.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff 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()))

0 commit comments

Comments
 (0)