diff options
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 } |