diff options
| author | Christian Pointner <equinox@helsinki.at> | 2017-01-27 19:46:41 (GMT) |
|---|---|---|
| committer | Christian Pointner <equinox@helsinki.at> | 2017-01-27 19:46:41 (GMT) |
| commit | fbcf3776c59aae5e2e6c6e4c700af3da1489af1f (patch) | |
| tree | 6a7c9caa459e84a8dd19e14dec77b044729636e6 /src/file-hasher/main.go | |
| parent | 056b224e3241c6cf889ba1c7b0eba85a8f33cc4a (diff) | |
seprate walker from hasher
Diffstat (limited to 'src/file-hasher/main.go')
| -rw-r--r-- | src/file-hasher/main.go | 11 |
1 files changed, 5 insertions, 6 deletions
diff --git a/src/file-hasher/main.go b/src/file-hasher/main.go index 1bb0132..051bb33 100644 --- a/src/file-hasher/main.go +++ b/src/file-hasher/main.go @@ -56,25 +56,24 @@ func main() { }() stdlog.Println("********************************************") - allFiles := make(FileMap) + h := NewHasher(4, stdlog) // TODO: make number of threads configurable for _, root := range directories { + d := NewDir(root, stdlog) stdlog.Printf("*** hashing all the files in '%s'", root) stdlog.Println("") - md := NewMusicDir(root, stdlog) - if err := md.ComputeHashes(); err != nil { + if err := h.ComputeHashes(d); err != nil { return } - allFiles.Merge(md.Files) stdlog.Println("") stdlog.Println("******************************") } stdlog.Println("") stdlog.Println("***************************************************************") - stdlog.Printf("*** hashed %d files in %v", len(allFiles), time.Since(starttime)) + stdlog.Printf("*** hashed %d files in %v", len(h.Files), time.Since(starttime)) stdlog.Println("***************************************************************") enc := json.NewEncoder(os.Stdout) - if err := enc.Encode(allFiles); err != nil { + if err := enc.Encode(h.Files); err != nil { stdlog.Printf("Error encoding JSON: %v", err) } }() |