From 383e075a62ca4e4250c1d652913c4de375a03bc5 Mon Sep 17 00:00:00 2001 From: Luke Shumaker Date: Sat, 19 May 2018 02:20:59 -0400 Subject: async status line --- go/src/cow-dedupe/dedupe.go | 7 ++++--- 1 file changed, 4 insertions(+), 3 deletions(-) (limited to 'go/src/cow-dedupe') diff --git a/go/src/cow-dedupe/dedupe.go b/go/src/cow-dedupe/dedupe.go index 9fee970..62fd85d 100644 --- a/go/src/cow-dedupe/dedupe.go +++ b/go/src/cow-dedupe/dedupe.go @@ -10,6 +10,7 @@ import ( "runtime" "strconv" "strings" + "time" "lib/statusline" ) @@ -34,7 +35,7 @@ func getFiemaps(paths []string) map[string][]string { ret := map[string][]string{} - sl := statusline.NewStatusLine(os.Stderr) + sl := statusline.NewAsyncStatusLine(os.Stderr, time.Second/2) cnt := 0 sl.Put("Mapping extents...") @@ -77,7 +78,7 @@ func getFiemaps(paths []string) map[string][]string { func getChecksums(paths []string) map[string][]string { ret := map[string][]string{} - sl := statusline.NewStatusLine(os.Stderr) + sl := statusline.NewAsyncStatusLine(os.Stderr, time.Second/2) cnt := 0 sl.Put(fmt.Sprintf("Generating checksums for files... %d/%d\n", cnt, len(paths))) @@ -128,7 +129,7 @@ func getChecksums(paths []string) map[string][]string { func main() { // we have low parallelism, don't let syscalls fan-out weird // on many-core systems - runtime.GOMAXPROCS(1) + runtime.GOMAXPROCS(2) fiemap2filenames := getFiemaps(os.Args[1:]) -- cgit v1.2.3-2-g168b