summaryrefslogtreecommitdiff
path: root/src/file-hasher/hasher.go
diff options
context:
space:
mode:
authorChristian Pointner <equinox@helsinki.at>2017-01-27 22:31:03 (GMT)
committerChristian Pointner <equinox@helsinki.at>2017-01-27 22:31:03 (GMT)
commitf1511737680385da81972bb76ec1ba1f2b6c46a1 (patch)
treeed14ac1afe969579be5a4d00a1a71e3304ad3332 /src/file-hasher/hasher.go
parenta04eca625d537ea899a4a88642c0a70e1d2032d5 (diff)
parse file-haser config as json from stdin
Diffstat (limited to 'src/file-hasher/hasher.go')
-rw-r--r--src/file-hasher/hasher.go6
1 files changed, 5 insertions, 1 deletions
diff --git a/src/file-hasher/hasher.go b/src/file-hasher/hasher.go
index afc35fd..27574f9 100644
--- a/src/file-hasher/hasher.go
+++ b/src/file-hasher/hasher.go
@@ -90,7 +90,7 @@ func (h *Hasher) collectHashes(C <-chan string) (wg *sync.WaitGroup) {
}
func (h *Hasher) ComputeHashes(w Walker) (err error) {
- C := make(chan string, 10)
+ C := make(chan string, h.numThreads*2)
wg := h.collectHashes(C)
@@ -106,5 +106,9 @@ func (h *Hasher) ComputeHashes(w Walker) (err error) {
func NewHasher(numThreads uint, stdlog *log.Logger) (h *Hasher) {
h = &Hasher{numThreads: numThreads, stdlog: stdlog}
h.Files = make(map[string]string)
+ if h.numThreads < 1 {
+ h.numThreads = 4
+ }
+ stdlog.Printf("*** Created blake2b based hasher (%d threads)", h.numThreads)
return
}