From 7c6aad17fa38be1b7a6657b00af407aee67b0aa3 Mon Sep 17 00:00:00 2001 From: Minh Doan Date: Thu, 13 Sep 2018 16:10:17 -0700 Subject: [PATCH] disable multicast --- node/node_handler.go | 2 +- p2p/peer.go | 3 ++- 2 files changed, 3 insertions(+), 2 deletions(-) diff --git a/node/node_handler.go b/node/node_handler.go index 8982c0522..41d105191 100644 --- a/node/node_handler.go +++ b/node/node_handler.go @@ -43,7 +43,7 @@ func (node *Node) NodeHandler(conn net.Conn) { node.log.Error("Read p2p data failed", "err", err, "node", node) return } - node.MaybeBroadcastAsValidator(content) + // node.MaybeBroadcastAsValidator(content) consensusObj := node.Consensus diff --git a/p2p/peer.go b/p2p/peer.go index 5e16ae7ce..7c9941ee7 100644 --- a/p2p/peer.go +++ b/p2p/peer.go @@ -68,7 +68,8 @@ func SelectMyPeers(peers []Peer, min int, max int) []Peer { // BroadcastMessage sends the message to a list of peers from a leader. func BroadcastMessageFromLeader(peers []Peer, msg []byte) { - peers = SelectMyPeers(peers, 0, MAX_BROADCAST-1) + // TODO(minhdoan): Enable back for multicast. + // peers = SelectMyPeers(peers, 0, MAX_BROADCAST-1) BroadcastMessage(peers, msg) }