From 7df9111d9f24f12417cc4938c7e859d97b45680e Mon Sep 17 00:00:00 2001
From: KatolaZ <katolaz@freaknet.org>
Date: Tue, 18 Jul 2017 16:24:49 +0100
Subject: The pipeline "spooling -> routing -> file deletion" works

---
 workers.go | 13 ++++++++++---
 1 file changed, 10 insertions(+), 3 deletions(-)

(limited to 'workers.go')

diff --git a/workers.go b/workers.go
index 33c6166..81281df 100644
--- a/workers.go
+++ b/workers.go
@@ -9,6 +9,7 @@ import (
 	"os"
 	"regexp"
 	"strings"
+	"time"
 )
 
 func (worker *SCORSHworker) Matches(repo, branch string) bool {
@@ -80,20 +81,26 @@ func Worker(w *SCORSHworker) {
 	var msg SCORSHmsg
 
 	log.Printf("[worker: %s] Started\n", w.Name)
+	debug.log("[worker: %s] MsgChan: %s\n", w.Name, w.MsgChan)
 
+	// notify that we have been started!
 	w.StatusChan <- msg
 
 	// This is the main worker loop
 	for {
 		select {
 		case msg = <-w.MsgChan:
-			debug.log("[worker: %s] received message %s\n", w.Name, msg.Name)
+			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)
 			// }
-			log.Printf("[worker: %s] Received message: ", w.Name, msg)
+			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)
+			w.StatusChan <- msg
+			debug.log("[worker: %s] Sent message back: %s", w.Name, msg)
 		}
 	}
 }
@@ -113,7 +120,7 @@ func StartWorkers(master *SCORSHmaster) error {
 		worker := &(master.Workers[w])
 		// Set the Status and Msg channels
 		worker.StatusChan = master.StatusChan
-		worker.MsgChan = make(chan SCORSHmsg)
+		worker.MsgChan = make(chan SCORSHmsg, 10)
 		// Load worker keyrings
 		err := worker.LoadKeyrings()
 		if err != nil {
-- 
cgit v1.2.3