Method lead

core/run.go:234–288

lead is called by the core/leader package when this cored instance becomes leader of the Core.

(ctx context.Context)

// lead is called by the core/leader package when this cored instance
// becomes leader of the Core.
func (a *API) lead(ctx context.Context) {
	if !a.config.IsGenerator {
		fetch.Init(ctx, a.remoteGenerator)
		// If don't have any blocks, bootstrap from the generator's
		// latest snapshot.
		if a.chain.Height() == 0 {
			sp := fetch.BootstrapSnapshot(ctx, a.chain, a.store, a.remoteGenerator, a.healthSetter("fetch"))

			// Save the downloading snapshot to the api so that /info can
			// return its current status.
			a.downloadingSnapshotMu.Lock()
			a.downloadingSnapshot = sp
			a.downloadingSnapshotMu.Unlock()
			// Wait for the snapshot download to finish before continuing.
			sp.Wait()
		}
	}

	// This process just became leader, so it's responsible
	// for recovering after the previous leader's exit.
	_, _, err := a.chain.Recover(ctx)
	if err != nil {
		log.Fatalkv(ctx, log.KeyError, err)
	}

	// Create all of the block processor pins if they don't already exist.
	pinHeight := a.chain.Height()
	if pinHeight > 0 {
		pinHeight = pinHeight - 1
	}
	pins := []string{account.PinName, account.ExpirePinName, account.DeleteSpentsPinName, asset.PinName, query.TxPinName}
	for _, p := range pins {
		err = a.pinStore.CreatePin(ctx, p, pinHeight)
		if err != nil {
			log.Fatalkv(ctx, log.KeyError, err)
		}
	}

	if a.config.IsGenerator {
		go a.generator.Generate(ctx, blockPeriod, a.healthSetter("generator"))
	} else {
		// Remove the downloading snapshot if there was one. The core
		// has recovered and will now start syncing blocks.
		a.downloadingSnapshotMu.Lock()
		a.downloadingSnapshot = nil
		a.downloadingSnapshotMu.Unlock()

		go fetch.Fetch(ctx, a.chain, a.remoteGenerator, a.healthSetter("fetch"))
	}
	go a.accounts.ProcessBlocks(ctx)
	go a.assets.ProcessBlocks(ctx)
	if a.indexTxs {
		go a.indexer.ProcessBlocks(ctx)
	}
}