diff options
author | Christian Pointner <equinox@helsinki.at> | 2017-01-27 22:31:03 (GMT) |
---|---|---|
committer | Christian Pointner <equinox@helsinki.at> | 2017-01-27 22:31:03 (GMT) |
commit | f1511737680385da81972bb76ec1ba1f2b6c46a1 (patch) | |
tree | ed14ac1afe969579be5a4d00a1a71e3304ad3332 /src/file-hasher/hasher.go | |
parent | a04eca625d537ea899a4a88642c0a70e1d2032d5 (diff) |
parse file-haser config as json from stdin
Diffstat (limited to 'src/file-hasher/hasher.go')
-rw-r--r-- | src/file-hasher/hasher.go | 6 |
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 } |