Method syncCurrentHead

blockproducer/chain.go:645–677

syncCurrentHead synchronizes a block at the current height of the local peer from the known remote peers. The return value `ok` indicates that there're at least `requiredReachable-1` replies from these gossip calls.

(ctx context.Context, requiredReachable uint32)

// remote peers. The return value `ok` indicates that there're at least `requiredReachable-1`
// replies from these gossip calls.
func (c *Chain) syncCurrentHead(ctx context.Context, requiredReachable uint32) (ok bool) {
	var currentHeight = c.getNextHeight() - 1
	if c.head().height >= currentHeight {
		ok = true
		return
	}

	// Initiate blocking gossip calls to fetch block of the current height,
	// with timeout of one tick.
	var (
		unreachable = c.blockingFetchBlock(ctx, currentHeight)
		serversNum  = c.getLocalBPInfo().total
	)

	switch c.mode {
	case BPMode:
		ok = unreachable+requiredReachable <= serversNum
	case APINodeMode:
		ok = unreachable < serversNum
	default:
		ok = false
		log.Fatalf("unknown run mode: %v", c.mode)
	}

	if !ok {
		log.WithFields(log.Fields{
			"peer":              c.getLocalBPInfo(),
			"sync_head_height":  currentHeight,
			"unreachable_count": unreachable,
		}).Warn("one or more block producers are currently unreachable")
	}
	return
}

func (c *Chain) storeTx(tx pi.Transaction) (err error) {
	var k = tx.Hash()