Method syncHeads

blockproducer/chain.go:439–468

()

}

func (c *Chain) syncHeads() {
	for {
		var (
			now       = c.now()
			nowHeight uint32
		)
		if now.Before(c.genesisTime) {
			log.WithFields(log.Fields{
				"local": c.getLocalBPInfo(),
			}).Info("now time is before genesis time, waiting for genesis")
			break
		}
		if nowHeight = c.heightOfTime(c.now()); c.getNextHeight() > nowHeight {
			break
		}
		for c.getNextHeight() <= nowHeight {
			// TODO(leventeliu): use the test mode flag to bypass the long-running synchronizing
			// on startup by now, need better solution here.
			if conf.GConf.StartupSyncHoles {
				log.WithFields(log.Fields{
					"local":       c.getLocalBPInfo(),
					"next_height": c.getNextHeight(),
					"now_height":  nowHeight,
				}).Debug("synchronizing head blocks")
				c.blockingSyncCurrentHead(c.ctx, conf.BPStartupRequiredReachableCount)
			}
			c.increaseNextHeight()
		}
	}
}

func (c *Chain) processBlocks(ctx context.Context) {
	for {