Method MaybeGenerateRangeCheckpoint

internal/epoch/epoch_manager.go:588–614

MaybeGenerateRangeCheckpoint may create a new range index for all the individual epochs covered by the new range. If there are not enough epochs to create a new range, then a range index is not created.

(ctx context.Context)

// individual epochs covered by the new range. If there are not enough epochs
// to create a new range, then a range index is not created.
func (e *Manager) MaybeGenerateRangeCheckpoint(ctx context.Context) (*maintenancestats.GenerateRangeCheckpointStats, error) {
	p, err := e.getParameters(ctx)
	if err != nil {
		return nil, err
	}

	cs, err := e.committedState(ctx, 0)
	if err != nil {
		return nil, err
	}

	firstNonRangeCompacted, latestSettled, compact := getRangeToCompact(cs, *p)
	if !compact {
		contentlog.Log(ctx, e.log, "not generating range checkpoint")

		return nil, nil
	}

	if err := e.generateRangeCheckpointFromCommittedState(ctx, cs, firstNonRangeCompacted, latestSettled); err != nil {
		return nil, errors.Wrap(err, "unable to generate full checkpoint, performance will be affected")
	}

	return &maintenancestats.GenerateRangeCheckpointStats{
		RangeMinEpoch: maintenancestats.ToUint64(firstNonRangeCompacted),
		RangeMaxEpoch: maintenancestats.ToUint64(latestSettled),
	}, nil
}

func getRangeToCompact(cs CurrentSnapshot, p Parameters) (low, high int, compactRange bool) {
	latestSettled := cs.lastSettledEpochNumber()