Method GossipConsensus

controller/consensus.go:364–378

GossipConsensus() gossips a consensus message through the P2P network for a specific chainId

(message *bft.Message, senderPubToExclude []byte)

// GossipConsensus() gossips a consensus message through the P2P network for a specific chainId
func (c *Controller) GossipConsensus(message *bft.Message, senderPubToExclude []byte) {
	// log the start of the gossip consensus message function
	var phase lib.Phase
	if message.Qc == nil {
		phase = message.Header.Phase
	} else {
		phase = message.Qc.Header.Phase
	}
	c.log.Debugf("Gossiping consensus message: P: %s %s", phase,
		crypto.HashString([]byte(message.String())))
	// send the consensus message to all peers excluding the sender (gossip)
	if err := c.P2P.SendToPeers(Cons, message, lib.BytesToString(senderPubToExclude)); err != nil {
		c.log.Errorf("unable to gossip consensus message with err: %s", err.Error())
	}
}

// ListenForBlockRequests() listen for inbound block request messages from syncing peers, handles and answer them
func (c *Controller) ListenForBlockRequests() {