summaryrefslogtreecommitdiff
path: root/workers.go
diff options
context:
space:
mode:
authorKatolaZ <katolaz@freaknet.org>2017-07-26 10:26:59 +0100
committerKatolaZ <katolaz@freaknet.org>2017-07-26 10:26:59 +0100
commit3fcaf22bbb9425f2f393dcbba492912a8a246f92 (patch)
tree356ce72981677d500d05c6aa0b9613ec39f764a7 /workers.go
parente6af4d1a5ce976fb74c70760675f7f31767f734d (diff)
A first go at gometalinter :-)
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 66dc6b0..2562b68 100644
--- a/workers.go
+++ b/workers.go
@@ -86,7 +86,7 @@ func (w *SCORSHworker) LoadTags() error {
}
// FIXME--- still needs some work...
-func Worker(w *SCORSHworker) {
+func runWorker(w *SCORSHworker) {
var msg SCORSHmsg
@@ -101,7 +101,7 @@ 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)
+ err := walkCommits(msg, w)
if err != nil {
log.Printf("[worker: %s] error in walk_commits: %s", err)
}
@@ -113,7 +113,7 @@ func Worker(w *SCORSHworker) {
// StartWorkers starts all the workers specified in a given
// configuration and fills in the SCORSHmaster struct
-func StartWorkers(master *SCORSHmaster) error {
+func startWorkers(master *SCORSHmaster) error {
num_workers := len(master.Workers)
@@ -146,7 +146,7 @@ func StartWorkers(master *SCORSHmaster) error {
for _, repo_name := range worker.Repos {
master.Repos[repo_name] = append(master.Repos[repo_name], worker)
}
- go Worker(worker)
+ go runWorker(worker)
<-master.StatusChan
}
return nil