Method nonblockingBroadcastBlock

blockproducer/chain_gossip.go:31–55

(block *types.BPBlock)

)

func (c *Chain) nonblockingBroadcastBlock(block *types.BPBlock) {
	for _, info := range c.getRemoteBPInfos() {
		func(remote *blockProducerInfo) {
			c.goFuncWithTimeout(func(ctx context.Context) {
				var (
					req = &types.AdviseNewBlockReq{
						Envelope: proto.Envelope{
							// TODO(lambda): Add fields.
						},
						Block: block,
					}
					err = c.caller.CallNodeWithContext(
						ctx, remote.nodeID, route.MCCAdviseNewBlock.String(), req, nil)
				)
				log.WithFields(log.Fields{
					"local":       c.getLocalBPInfo(),
					"remote":      remote,
					"block_time":  block.Timestamp(),
					"block_hash":  block.BlockHash().Short(4),
					"parent_hash": block.ParentHash().Short(4),
				}).WithError(err).Debug("broadcast new block to other peers")
			}, c.period)
		}(info)
	}
}

func (c *Chain) nonblockingBroadcastTx(ttl uint32, tx pi.Transaction) {
	for _, info := range c.getRemoteBPInfos() {