Function runCheck

cmd/restic/cmd_check.go:229–429

(ctx context.Context, opts CheckOptions, gopts global.Options, args []string, term ui.Terminal)

}

func runCheck(ctx context.Context, opts CheckOptions, gopts global.Options, args []string, term ui.Terminal) (checkSummary, error) {
	summary := checkSummary{MessageType: "summary"}

	var printer progress.Printer
	if !gopts.JSON {
		printer = ui.NewProgressPrinter(gopts.JSON, gopts.Verbosity, term)
	} else {
		printer = newJSONErrorPrinter(term)
	}

	cleanup := prepareCheckCache(opts, &gopts, printer)
	defer cleanup()

	if !gopts.NoLock {
		printer.P("create exclusive lock for repository\n")
	}
	ctx, repo, unlock, err := openWithExclusiveLock(ctx, gopts, gopts.NoLock, printer)
	if err != nil {
		return summary, err
	}
	defer unlock()

	chkr := checker.New(repo, opts.CheckUnused)
	err = chkr.LoadSnapshots(ctx, &opts.SnapshotFilter, args)
	if err != nil {
		return summary, err
	}

	printer.P("load indexes\n")
	hints, errs := chkr.LoadIndex(ctx, printer)
	if ctx.Err() != nil {
		return summary, ctx.Err()
	}

	errorsFound := false
	salvagePacks := restic.NewIDSet()

	for _, hint := range hints {
		switch hint := hint.(type) {
		case *repository.ErrIncompletePackEntry:
			printer.E("%s", hint.Error())
			salvagePacks.Insert(hint.PackID)
			errorsFound = true
			summary.NumErrors++
		case *repository.ErrDuplicatePacks:
			printer.S("%s", hint.Error())
			summary.HintRepairIndex = true
		case *repository.ErrMixedPack:
			printer.S("%s", hint.Error())
			summary.HintPrune = true
		default:
			printer.E("error: %v\n", hint)
			errorsFound = true
		}
	}

	if summary.HintRepairIndex {
		printer.S("Duplicate packs are non-critical, you can run `restic repair index' to correct this.\n")