From 331ff076bb2e56fc83768b751f1cda1554afbed6 Mon Sep 17 00:00:00 2001
From: Jarek Kowalski <jaak@jkowalski.net>
Date: Sat, 14 Mar 2020 15:26:20 -0700
Subject: [PATCH] cli: added number of files that are in the process of being
 hashed

---
 cli/cli_progress.go | 17 +++++++++++++----
 1 file changed, 13 insertions(+), 4 deletions(-)

diff --git a/cli/cli_progress.go b/cli/cli_progress.go
index 1d2bfc449..c633a196e 100644
--- a/cli/cli_progress.go
+++ b/cli/cli_progress.go
@@ -22,9 +22,10 @@ type cliProgress struct {
 	hashedBytes            int64
 	nextOutputTimeUnixNano int64
 
-	cachedFiles   int32
-	hashedFiles   int32
-	uploadedFiles int32
+	cachedFiles       int32
+	inProgressHashing int32
+	hashedFiles       int32
+	uploadedFiles     int32
 
 	uploading      int32
 	uploadFinished int32
@@ -40,8 +41,13 @@ type cliProgress struct {
 	shared bool
 }
 
+func (p *cliProgress) HashingFile(fname string) {
+	atomic.AddInt32(&p.inProgressHashing, 1)
+}
+
 func (p *cliProgress) FinishedHashingFile(fname string, totalSize int64) {
 	atomic.AddInt32(&p.hashedFiles, 1)
+	atomic.AddInt32(&p.inProgressHashing, -1)
 	p.maybeOutput()
 }
 
@@ -89,13 +95,16 @@ func (p *cliProgress) output() {
 	cachedBytes := atomic.LoadInt64(&p.cachedBytes)
 	uploadedBytes := atomic.LoadInt64(&p.uploadedBytes)
 	cachedFiles := atomic.LoadInt32(&p.cachedFiles)
+	inProgressHashing := atomic.LoadInt32(&p.inProgressHashing)
 	hashedFiles := atomic.LoadInt32(&p.hashedFiles)
 	uploadedFiles := atomic.LoadInt32(&p.uploadedFiles)
 
 	line := fmt.Sprintf(
-		" %v %v hashed (%v), %v cached (%v), %v uploaded (%v)",
+		" %v %v hashing, %v hashed (%v), %v cached (%v), %v uploaded (%v)",
 		p.spinnerCharacter(),
 
+		inProgressHashing,
+
 		hashedFiles,
 		units.BytesStringBase10(hashedBytes),