summaryrefslogtreecommitdiff
path: root/workers.go
diff options
context:
space:
mode:
authorKatolaZ <katolaz@freaknet.org>2017-07-19 06:36:00 +0100
committerKatolaZ <katolaz@freaknet.org>2017-07-19 06:36:00 +0100
commit40c8aae58491b07adb05d348d1ddf86ce5ec2be8 (patch)
tree52dae87ff1dc2a65a3fe45be5f18053fb0d62ac1 /workers.go
parent30e2f9e350197cfda09766ef34112e4e3eb261b9 (diff)
Added Licence. Amended Makefile: scorsh -> scorshd. getting closer.
Diffstat (limited to 'workers.go')
-rw-r--r--workers.go8
1 files changed, 4 insertions, 4 deletions
diff --git a/workers.go b/workers.go
index 81281df..c48c65f 100644
--- a/workers.go
+++ b/workers.go
@@ -92,10 +92,10 @@ func Worker(w *SCORSHworker) {
case msg = <-w.MsgChan:
debug.log("[worker: %s] received message %s\n", w.Name, msg.Id)
// process message
- // err := walk_commits(msg, w)
- // if err != nil {
- // log.Printf("[worker: %s] error in walk_commits: %s", err)
- // }
+ err := walk_commits(msg, w)
+ if err != nil {
+ log.Printf("[worker: %s] error in walk_commits: %s", err)
+ }
debug.log("[worker: %s] Received message: %s", w.Name, msg)
debug.log("[worker: %s] StatusChan: %s\n", w.Name, w.StatusChan)
time.Sleep(1000 * time.Millisecond)