Method output

cli/restore_progress.go:63–116

(suffix string)

}

func (p *cliRestoreProgress) output(suffix string) {
	if !p.enableProgress {
		return
	}

	// ensure the counters are not going back in an output line compared to the previous one
	p.outputMutex.Lock()
	defer p.outputMutex.Unlock()

	restoredCount := p.restoredCount.Load()
	enqueuedCount := p.enqueuedCount.Load()
	skippedCount := p.skippedCount.Load()
	ignoredCount := p.ignoredErrorsCount.Load()

	restoredSize := p.restoredTotalFileSize.Load()
	enqueuedSize := p.enqueuedTotalFileSize.Load()
	skippedSize := p.skippedTotalFileSize.Load()

	if restoredSize == 0 {
		return
	}

	var maybeRemaining, maybeSkipped, maybeErrors string
	if est, ok := p.eta.Estimate(float64(restoredSize), float64(enqueuedSize)); ok {
		maybeRemaining = fmt.Sprintf(" %v (%.1f%%) remaining %v",
			units.BytesPerSecondsString(est.SpeedPerSecond),
			est.PercentComplete,
			est.Remaining)
	}

	if skippedCount > 0 {
		maybeSkipped = fmt.Sprintf(", skipped %v (%v)", skippedCount, units.BytesString(skippedSize))
	}

	if ignoredCount > 0 {
		maybeErrors = fmt.Sprintf(", ignored %v errors", ignoredCount)
	}

	line := fmt.Sprintf("Processed %v (%v) of %v (%v)%v%v%v.",
		restoredCount+skippedCount, units.BytesString(restoredSize),
		enqueuedCount, units.BytesString(enqueuedSize),
		maybeSkipped, maybeErrors, maybeRemaining,
	)

	var extraSpaces string

	if len(line) < p.lastLineLength {
		// add extra spaces to wipe over previous line if it was longer than current
		extraSpaces = strings.Repeat(" ", p.lastLineLength-len(line))
	}

	p.lastLineLength = len(line)
	p.out.printStderr("\r%v%v%v", line, extraSpaces, suffix)
}