Method mainCycle

blockproducer/chain.go:580–617

(ctx context.Context)

}

func (c *Chain) mainCycle(ctx context.Context) {
	var timer = time.NewTimer(0)
	defer func() {
		if !timer.Stop() {
			<-timer.C
		}
	}()
	for {
		select {
		case <-timer.C:
			// Try to fetch block at height `nextHeight-1` until enough peers are reachable
			if err := c.blockingSyncCurrentHead(ctx, c.getRequiredConfirms()); err != nil {
				log.WithError(err).Info("abort main cycle")
				timer.Reset(0)
				return
			}

			var t, d = c.nextTick()
			if d <= 0 {
				// Try to produce block at `nextHeight` if it's my turn, and increase height by 1
				c.advanceNextHeight(t, d)
			} else {
				log.WithFields(log.Fields{
					"peer":        c.getLocalBPInfo(),
					"next_height": c.getNextHeight(),
					"head_height": c.head().height,
					"head_block":  c.head().hash.Short(4),
					"now_time":    t.Format(time.RFC3339Nano),
					"duration":    d,
				}).Debug("main cycle")
			}
			timer.Reset(d)
		case <-ctx.Done():
			log.WithError(ctx.Err()).Info("abort main cycle")
			return
		}
	}
}

func (c *Chain) blockingSyncCurrentHead(ctx context.Context, requiredReachable uint32) (err error) {
	var (