2
2
mirror of https://github.com/octoleo/restic.git synced 2024-11-26 14:56:29 +00:00

cmd/restic: Streamline progress printing

* PrintProgress no longer does unnecessary Sprintf calls, and performs
  fewer allocations in general
* newProgressMax's callback checks whether the terminal supports
  line updates once instead of once per call
* the callback looks up the terminal width once per call instead of
  twice (on Windows)
* the status shortening now uses the Unicode-aware version from
  internal/ui/termstatus (future-proofing)
This commit is contained in:
greatroar 2021-08-29 14:55:33 +02:00
parent 5aaa3e93c1
commit 7f0aa49f45
4 changed files with 46 additions and 52 deletions

View File

@ -58,7 +58,7 @@ func RunCleanupHandlers() {
func CleanupHandler(c <-chan os.Signal) { func CleanupHandler(c <-chan os.Signal) {
for s := range c { for s := range c {
debug.Log("signal %v received, cleaning up", s) debug.Log("signal %v received, cleaning up", s)
Warnf("%ssignal %v received, cleaning up\n", ClearLine(), s) Warnf("%ssignal %v received, cleaning up\n", clearLine(0), s)
code := 0 code := 0

View File

@ -119,18 +119,6 @@ func verifyPruneOptions(opts *PruneOptions) error {
return nil return nil
} }
func shortenStatus(maxLength int, s string) string {
if len(s) <= maxLength {
return s
}
if maxLength < 3 {
return s[:maxLength]
}
return s[:maxLength-3] + "..."
}
func runPrune(opts PruneOptions, gopts GlobalOptions) error { func runPrune(opts PruneOptions, gopts GlobalOptions) error {
err := verifyPruneOptions(&opts) err := verifyPruneOptions(&opts)
if err != nil { if err != nil {

View File

@ -197,16 +197,21 @@ func restoreTerminal() {
} }
// ClearLine creates a platform dependent string to clear the current // ClearLine creates a platform dependent string to clear the current
// line, so it can be overwritten. ANSI sequences are not supported on // line, so it can be overwritten.
// current windows cmd shell. //
func ClearLine() string { // w should be the terminal width, or 0 to let clearLine figure it out.
if runtime.GOOS == "windows" { func clearLine(w int) string {
if w := stdoutTerminalWidth(); w > 0 { if runtime.GOOS != "windows" {
return strings.Repeat(" ", w-1) + "\r" return "\x1b[2K"
}
return ""
} }
return "\x1b[2K"
// ANSI sequences are not supported on Windows cmd shell.
if w <= 0 {
if w = stdoutTerminalWidth(); w <= 0 {
return ""
}
}
return strings.Repeat(" ", w-1) + "\r"
} }
// Printf writes the message to the configured stdout stream. // Printf writes the message to the configured stdout stream.
@ -247,31 +252,6 @@ func Verboseff(format string, args ...interface{}) {
} }
} }
// PrintProgress wraps fmt.Printf to handle the difference in writing progress
// information to terminals and non-terminal stdout
func PrintProgress(format string, args ...interface{}) {
var (
message string
carriageControl string
)
message = fmt.Sprintf(format, args...)
if !(strings.HasSuffix(message, "\r") || strings.HasSuffix(message, "\n")) {
if stdoutCanUpdateStatus() {
carriageControl = "\r"
} else {
carriageControl = "\n"
}
message = fmt.Sprintf("%s%s", message, carriageControl)
}
if stdoutCanUpdateStatus() {
message = fmt.Sprintf("%s%s", ClearLine(), message)
}
fmt.Print(message)
}
// Warnf writes the message to the configured stderr stream. // Warnf writes the message to the configured stderr stream.
func Warnf(format string, args ...interface{}) { func Warnf(format string, args ...interface{}) {
_, err := fmt.Fprintf(globalOptions.stderr, format, args...) _, err := fmt.Fprintf(globalOptions.stderr, format, args...)

View File

@ -4,9 +4,11 @@ import (
"fmt" "fmt"
"os" "os"
"strconv" "strconv"
"strings"
"time" "time"
"github.com/restic/restic/internal/ui/progress" "github.com/restic/restic/internal/ui/progress"
"github.com/restic/restic/internal/ui/termstatus"
) )
// calculateProgressInterval returns the interval configured via RESTIC_PROGRESS_FPS // calculateProgressInterval returns the interval configured via RESTIC_PROGRESS_FPS
@ -32,6 +34,7 @@ func newProgressMax(show bool, max uint64, description string) *progress.Counter
return nil return nil
} }
interval := calculateProgressInterval(show) interval := calculateProgressInterval(show)
canUpdateStatus := stdoutCanUpdateStatus()
return progress.New(interval, max, func(v uint64, max uint64, d time.Duration, final bool) { return progress.New(interval, max, func(v uint64, max uint64, d time.Duration, final bool) {
var status string var status string
@ -42,13 +45,36 @@ func newProgressMax(show bool, max uint64, description string) *progress.Counter
formatDuration(d), formatPercent(v, max), v, max, description) formatDuration(d), formatPercent(v, max), v, max, description)
} }
if w := stdoutTerminalWidth(); w > 0 { printProgress(status, canUpdateStatus)
status = shortenStatus(w, status)
}
PrintProgress("%s", status)
if final { if final {
fmt.Print("\n") fmt.Print("\n")
} }
}) })
} }
func printProgress(status string, canUpdateStatus bool) {
w := stdoutTerminalWidth()
if w > 0 {
if w < 3 {
status = termstatus.Truncate(status, w)
} else {
status = termstatus.Truncate(status, w-3) + "..."
}
}
var carriageControl, clear string
if canUpdateStatus {
clear = clearLine(w)
}
if !(strings.HasSuffix(status, "\r") || strings.HasSuffix(status, "\n")) {
if canUpdateStatus {
carriageControl = "\r"
} else {
carriageControl = "\n"
}
}
_, _ = os.Stdout.Write([]byte(clear + status + carriageControl))
}