Merge pull request #504 from ipfs/fix/task-worker-count-race

fix: hold the task worker lock when starting task workers
ipfs · Jun 24, 2021 · d48cee0 · d48cee0
2 parents f2385cb + 24c356f
commit d48cee0
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/internal/decision/engine.go b/internal/decision/engine.go
@@ -235,6 +235,9 @@ func (e *Engine) StartWorkers(ctx context.Context, px process.Process) {
 	e.bsm.start(px)
 	e.startScoreLedger(px)
 
+	e.taskWorkerLock.Lock()
+	defer e.taskWorkerLock.Unlock()
+
 	for i := 0; i < e.taskWorkerCount; i++ {
 		px.Go(func(px process.Process) {
 			e.taskWorker(ctx)