Makes scale chan nil if scaling is not active.

dunglas · Jan 27, 2025 · 755551a · 755551a
1 parent e3d38b5
commit 755551a
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/scaling.go b/scaling.go
@@ -32,8 +32,8 @@ const (
 )
 
 var (
+	scaleChan         chan *FrankenPHPContext
 	autoScaledThreads = []*phpThread{}
-	scaleChan         = make(chan *FrankenPHPContext)
 	scalingMu         = new(sync.RWMutex)
 	disallowScaling   = atomic.Bool{}
 
@@ -44,9 +44,11 @@ var (
 
 func initAutoScaling(mainThread *phpMainThread) {
 	if mainThread.maxThreads <= mainThread.numThreads {
+		scaleChan = nil
 		return
 	}
 
+	scaleChan = make(chan *FrankenPHPContext)
 	maxScaledThreads := mainThread.maxThreads - mainThread.numThreads
 	scalingMu.Lock()
 	autoScaledThreads = make([]*phpThread, 0, maxScaledThreads)