particle-os/debian-forge-composer
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

gen-manifests: inline finish() into wait()

Browse source 
wait() just did finish() and returned errors; no need for two
functions.
This commit is contained in:
Achilleas Koutsou 2022-05-30 11:58:38 +02:00 • committed by Tom Gundersen
parent 150d490ba8
commit d470a3cb3f
1 changed files with 2 additions and 6 deletions
Download patch file Download diff file Expand all files Collapse all files

8
cmd/gen-manifests/workerqueue.go
View file

@ -60,13 +60,8 @@ func (wq *workerQueue) start() {
} }
} }
func (wq *workerQueue) wait() []error {
wq.finish()
return wq.errors
}
// close all queues and wait for waitgroups // close all queues and wait for waitgroups
func (wq *workerQueue) finish() { func (wq *workerQueue) wait() []error {
// close job channel and wait for workers to finish // close job channel and wait for workers to finish
close(wq.jobQueue) close(wq.jobQueue)
wq.workerWG.Wait() wq.workerWG.Wait()
@ -75,6 +70,7 @@ func (wq *workerQueue) finish() {
close(wq.msgQueue) close(wq.msgQueue)
close(wq.errQueue) close(wq.errQueue)
wq.utilWG.Wait() wq.utilWG.Wait()
return wq.errors
} }
func (wq *workerQueue) startWorker(idx uint32) { func (wq *workerQueue) startWorker(idx uint32) {