From 3fcaf22bbb9425f2f393dcbba492912a8a246f92 Mon Sep 17 00:00:00 2001
From: KatolaZ <katolaz@freaknet.org>
Date: Wed, 26 Jul 2017 10:26:59 +0100
Subject: A first go at gometalinter :-)
---
workers.go | 8 ++++----
1 file changed, 4 insertions(+), 4 deletions(-)
(limited to 'workers.go')
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
--
cgit v1.2.3