Method blockingFetchBlock

blockproducer/chain_gossip.go:84–136

(ctx context.Context, h uint32)

}

func (c *Chain) blockingFetchBlock(ctx context.Context, h uint32) (unreachable uint32) {
	var (
		cld, ccl = context.WithTimeout(ctx, c.tick)
		wg       = &sync.WaitGroup{}
	)
	defer func() {
		wg.Wait()
		ccl()
	}()
	for _, info := range c.getRemoteBPInfos() {
		wg.Add(1)
		go func(remote *blockProducerInfo) {
			defer wg.Done()
			var (
				err error
				req = &types.FetchBlockReq{
					Envelope: proto.Envelope{
						// TODO(lambda): Add fields.
					},
					Height: h,
				}
				resp = &types.FetchBlockResp{}
			)
			var le = log.WithFields(log.Fields{
				"local":  c.getLocalBPInfo(),
				"remote": remote,
				"height": h,
			})
			if err = c.caller.CallNodeWithContext(
				cld, remote.nodeID, route.MCCFetchBlock.String(), req, resp,
			); err != nil {
				le.WithError(err).Warn("failed to fetch block")
				atomic.AddUint32(&unreachable, 1)
				return
			}
			if resp.Block == nil {
				le.Debug("fetch block request reply: no such block")
				return
			}
			// Push new block from other peers
			le.WithFields(log.Fields{
				"parent": resp.Block.ParentHash().Short(4),
				"hash":   resp.Block.BlockHash().Short(4),
			}).Debug("fetch block request reply: found block")
			select {
			case c.pendingBlocks <- resp.Block:
			case <-cld.Done():
				log.WithError(cld.Err()).Warn("add pending block aborted")
			}
		}(info)
	}
	return
}