async status line

1 files changed, 4 insertions, 3 deletions

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:])