diff options
| author | KatolaZ <katolaz@freaknet.org> | 2017-08-07 09:55:35 +0100 | 
|---|---|---|
| committer | KatolaZ <katolaz@freaknet.org> | 2017-08-07 09:55:35 +0100 | 
| commit | 096b3fd2867d7bb2d3cd1f85d8806c651b26d625 (patch) | |
| tree | 4dfcc77e86cc0e667c14a92c43d1785b4cb5e4b8 /scorshd.go | |
| parent | 802d703f617036ec1d18aa8ecb9678ca3390f68a (diff) | |
| parent | d3105e671a19fec1060652531ce783227fb9fab6 (diff) | |
Merge branch 'devel'
Diffstat (limited to 'scorshd.go')
| -rw-r--r-- | scorshd.go | 14 | 
1 files changed, 7 insertions, 7 deletions
| @@ -46,9 +46,9 @@ func SCORSHerr(err int) error {  } -func findMatchingWorkers(master *SCORSHmaster, msg *SCORSHmsg) []*SCORSHworker { +func findMatchingWorkers(master *master, msg *spoolMsg) []*worker { -	var ret []*SCORSHworker +	var ret []*worker  	for idx, w := range master.Workers {  		if w.Matches(msg.Repo, msg.Branch) { @@ -59,7 +59,7 @@ func findMatchingWorkers(master *SCORSHmaster, msg *SCORSHmsg) []*SCORSHworker {  	return ret  } -func runMaster(master *SCORSHmaster) { +func runMaster(master *master) {  	// master main loop: @@ -108,16 +108,16 @@ func runMaster(master *SCORSHmaster) {  	debug.log("[master] Exiting the for loop, for some mysterious reason...\n")  } -func initMaster() *SCORSHmaster { +func initMaster() *master {  	master := readGlobalConfig(*confFile) -	master.Repos = make(map[string][]*SCORSHworker) +	master.Repos = make(map[string][]*worker)  	master.WorkingMsg = make(map[string]int)  	// This is the channel on which we receive acks from workers -	master.StatusChan = make(chan SCORSHmsg) +	master.StatusChan = make(chan spoolMsg)  	// This is the channel on which we exchange messages with the spooler -	master.Spooler = make(chan SCORSHmsg) +	master.Spooler = make(chan spoolMsg)  	debug.log("[InitMaster] StatusChan: %s\n", master.StatusChan) | 
