Function startProgress

cmd/progress.go:27–71

startProgress starts the progress bar printing It returns a func which should be called to stop the stats.

()

//
// It returns a func which should be called to stop the stats.
func startProgress() func() {
	stopStats := make(chan struct{})
	oldSyncPrint := operations.SyncPrintf

	if !log.Redirected() {
		// Intercept the log calls if not logging to file or syslog
		log.Handler.SetOutput(func(level slog.Level, text string) {
			printProgress(text)
		})
	}

	// Intercept output from functions such as HashLister to stdout
	operations.SyncPrintf = func(format string, a ...any) {
		printProgress(fmt.Sprintf(format, a...))
	}

	var wg sync.WaitGroup
	wg.Go(func() {
		progressInterval := defaultProgressInterval
		if ShowStats() && *statsInterval > 0 {
			progressInterval = *statsInterval
		}
		ticker := time.NewTicker(progressInterval)
		for {
			select {
			case <-ticker.C:
				printProgress("")
			case <-stopStats:
				ticker.Stop()
				printProgress("")
				if !log.Redirected() {
					// Reset intercept of the log calls
					log.Handler.ResetOutput()
				}
				operations.SyncPrintf = oldSyncPrint
				fmt.Println("")
				return
			}
		}
	})
	return func() {
		close(stopStats)
		wg.Wait()
	}
}

// state for the progress printing
var (