blob: f51852eb435820f6dd4e7babf30a0e35707e65a0 (
about) (
plain) (
blame)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
|
package progress
import (
"fmt"
"strings"
"time"
"lindenii.org/go/furgit/internal/utils"
"lindenii.org/go/lgo/fmt/humanize"
"lindenii.org/go/lgo/intconv"
)
func (meter *Meter) render(now time.Time, eol string) {
if meter.delay > 0 && now.Sub(meter.startedAt) < meter.delay && eol == "\r" {
return
}
meter.refreshThroughput(now)
counters := meter.renderCounters()
clear1 := 0
if len(counters) < meter.lastCounterW {
clear1 = meter.lastCounterW - len(counters) + 1
}
meter.lastCounterW = len(counters)
line := meter.title + ": " + counters
if clear1 > 0 {
line += strings.Repeat(" ", clear1)
}
line += eol
utils.BestEffortFprintf(meter.writer, "%s", line)
if meter.writer != nil {
_ = meter.writer.Flush()
}
}
func (meter *Meter) renderCounters() string {
if meter.total > 0 {
u, err := intconv.Uint64ToInt(meter.lastDone * 100 / meter.total)
if err != nil {
return "overflow"
// TODO
}
meter.lastPercent = u
return fmt.Sprintf("%3d%% (%d/%d)%s", meter.lastPercent, meter.lastDone, meter.total, meter.throughputSuffix)
}
return fmt.Sprintf("%d%s", meter.lastDone, meter.throughputSuffix)
}
func (meter *Meter) refreshThroughput(now time.Time) {
if !meter.throughput {
return
}
if meter.nextThroughput.After(now) && meter.throughputSuffix != "" {
return
}
for !now.Before(meter.nextThroughput) {
meter.nextThroughput = meter.nextThroughput.Add(throughputInterval)
}
elapsed := now.Sub(meter.startedAt)
if elapsed <= 0 {
return
}
rate := uint64(float64(meter.lastBytes) / elapsed.Seconds())
meter.throughputSuffix = ", " + humanize.Bytes(meter.lastBytes) + " | " + humanize.Bytes(rate) + "/s"
}
|
