diff options
Diffstat (limited to 'src')
-rw-r--r-- | src/file-hasher/dir-hasher.go (renamed from src/pool-import/dir-hasher.go) | 0 | ||||
-rw-r--r-- | src/file-hasher/main.go | 81 | ||||
-rw-r--r-- | src/pool-import/main.go | 20 |
3 files changed, 82 insertions, 19 deletions
diff --git a/src/pool-import/dir-hasher.go b/src/file-hasher/dir-hasher.go index aa204a0..aa204a0 100644 --- a/src/pool-import/dir-hasher.go +++ b/src/file-hasher/dir-hasher.go diff --git a/src/file-hasher/main.go b/src/file-hasher/main.go new file mode 100644 index 0000000..c25f690 --- /dev/null +++ b/src/file-hasher/main.go @@ -0,0 +1,81 @@ +// +// pool-import +// +// Copyright (C) 2016 Christian Pointner <equinox@helsinki.at> +// +// This file is part of pool-import. +// +// pool-import is free software: you can redistribute it and/or modify +// it under the terms of the GNU General Public License as published by +// the Free Software Foundation, either version 3 of the License, or +// any later version. +// +// pool-import is distributed in the hope that it will be useful, +// but WITHOUT ANY WARRANTY; without even the implied warranty of +// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the +// GNU General Public License for more details. +// +// You should have received a copy of the GNU General Public License +// along with pool-import. If not, see <http://www.gnu.org/licenses/>. +// + +package main + +import ( + "log" + "os" + "os/signal" + "syscall" + "time" +) + +const ( + RD_CONF = "/etc/rd.conf" +) + +func main() { + if len(os.Args) < 2 { + log.Fatal("Usage: file-hasher <directory> [ <directory [ .. ] ]") + } + directories := os.Args[1:] + + stdlog := log.New(os.Stderr, "[std] ", log.LstdFlags) + + C := make(chan os.Signal, 1) + signal.Notify(C, os.Interrupt, syscall.SIGHUP, syscall.SIGQUIT, syscall.SIGTERM) + + stdlog.Println("***************************************************************") + stdlog.Printf("*** will hash files' from %d directories", len(directories)) + stdlog.Println("***************************************************************") + + starttime := time.Now() + go func() { + defer func() { + C <- syscall.SIGTERM + }() + + stdlog.Println("********************************************") + allFiles := make(FileMap) + for _, root := range directories { + stdlog.Printf("*** hashing all the files in '%s'", root) + stdlog.Println("") + md := NewMusicDir(root, stdlog) + if err := md.ComputeHashes(); err != nil { + return + } + allFiles.Merge(md.Files) + stdlog.Println("") + stdlog.Println("******************************") + } + stdlog.Println("") + for hash, file := range allFiles { + stdlog.Printf("%s: %s", hash, file) + } + stdlog.Println("") + stdlog.Println("***************************************************************") + stdlog.Printf("*** hashed %d files in %v", len(allFiles), time.Since(starttime)) + stdlog.Println("***************************************************************") + }() + + <-C +} diff --git a/src/pool-import/main.go b/src/pool-import/main.go index 10a59ec..0963ed0 100644 --- a/src/pool-import/main.go +++ b/src/pool-import/main.go @@ -96,25 +96,7 @@ func main() { C <- syscall.SIGTERM }() - stdlog.Println("********************************************") - allFiles := make(FileMap) - for _, root := range directories { - stdlog.Printf("*** hashing all the files in '%s'", root) - stdlog.Println("") - md := NewMusicDir(root, stdlog) - if err := md.ComputeHashes(); err != nil { - return - } - allFiles.Merge(md.Files) - stdlog.Println("") - stdlog.Println("******************************") - } - stdlog.Println("") - for hash, file := range allFiles { - stdlog.Printf("%s: %s", hash, file) - } - stdlog.Println("") - stdlog.Println("********************************************") + // TODO: use file-hasher to get file hashes }() <-C |