syz-ci: explicitly stop all running jobs on update

Otherwise we might end up in a situation when we have stopped all
fuzzing, but wait for the job processor to report Done to the waitgroup
object.

1 files changed, 17 insertions, 0 deletions

diff --git a/syz-ci/jobs.go b/syz-ci/jobs.go
index fcdca9ada..04c241ab2 100644
--- a/syz-ci/jobs.go
+++ b/syz-ci/jobs.go
@@ -58,6 +58,23 @@ func newJobManager(cfg *Config, managers []*Manager, shutdownPending chan struct
 	}, nil
 }
 
+// startLoop starts a job loop in parallel and returns a blocking function
+// to gracefully stop job processing.
+func (jm *JobManager) startLoop(wg *sync.WaitGroup) func() {
+	stop := make(chan struct{})
+	done := make(chan struct{}, 1)
+	wg.Add(1)
+	go func() {
+		defer wg.Done()
+		jm.loop(stop)
+		done <- struct{}{}
+	}()
+	return func() {
+		stop <- struct{}{}
+		<-done
+	}
+}
+
 func (jm *JobManager) loop(stop chan struct{}) {
 	if err := jm.resetJobs(); err != nil {
 		if jm.dash != nil {