X-Git-Url: http://www.git.cypherpunks.ru/?a=blobdiff_plain;f=log.go;h=4d8a982813a1e58a31c43fafbcad3f4d2d4336dd;hb=009b34e1c2f6bfe89b33d96697879b33d9b901dc;hp=703f198368d7b9886c91029962c58a4f3b40dead;hpb=cd29a67e26ef05f0ffadd83448f09886edef4111;p=goredo.git diff --git a/log.go b/log.go index 703f198..4d8a982 100644 --- a/log.go +++ b/log.go @@ -68,8 +68,8 @@ var ( flagLogPid = flag.Bool("log-pid", false, fmt.Sprintf("append PIDs (%s=1)", EnvLogPid)) flagLogJS = flag.Bool("log-js", false, fmt.Sprintf("enable jobserver messages logging (%s=1)", EnvLogJS)) - LogMutex sync.Mutex - LogLenPrev int + LogMutex sync.Mutex + KeyEraseLine string ) func init() { @@ -83,17 +83,14 @@ func init() { CWarn = string(t.Escape.Magenta) CJS = string(t.Escape.White) CReset = string(t.Escape.Reset) + KeyEraseLine = fmt.Sprintf("%s[K", CReset[0:1]) } -func fillUpToTermSize(s, end string) string { - sLen := len(s) - if sLen < LogLenPrev { - s += strings.Repeat(" ", LogLenPrev-sLen) - LogLenPrev = sLen - } else { - LogLenPrev = sLen +func erasedStatus(s, end string) string { + if NoProgress { + return s + end } - return s + end + return s + KeyEraseLine + end } func trace(level, format string, args ...interface{}) { @@ -103,10 +100,9 @@ func trace(level, format string, args ...interface{}) { } switch level { case CNone: + p = erasedStatus(StderrPrefix+p+fmt.Sprintf(format, args...), "\n") LogMutex.Lock() - os.Stderr.WriteString(fillUpToTermSize( - StderrPrefix+p+fmt.Sprintf(format, args...), "\n", - )) + os.Stderr.WriteString(p) LogMutex.Unlock() return case CDebug: @@ -141,8 +137,9 @@ func trace(level, format string, args ...interface{}) { } msg := fmt.Sprintf(format, args...) msg = StderrPrefix + colourize(level, p+strings.Repeat(". ", Level)+msg) + msg = erasedStatus(msg, "\n") LogMutex.Lock() - os.Stderr.WriteString(fillUpToTermSize(msg, "\n")) + os.Stderr.WriteString(msg) LogMutex.Unlock() }