hmm

Author: henderkes

worker.go

@@ -37,15 +37,15 @@ func initWorkers(opt []workerOpt) error {
 
 	for _, o := range opt {
 		worker, err := newWorker(o)
-		if err != nil {
-			return err
-		}
 		if worker.threads == nil {
 			worker.threads = make([]*phpThread, 0, o.num)
 		} else {
 			worker.num += o.num
 		}
 		workersReady.Add(o.num)
+		if err != nil {
+			return err
+		}
 		for i := 0; i < o.num; i++ {
 			thread := getInactivePHPThread()
 			convertToWorkerThread(thread, worker)
@@ -76,12 +76,6 @@ func newWorker(o workerOpt) (*worker, error) {
 		return nil, fmt.Errorf("worker filename is invalid %q: %w", o.fileName, err)
 	}
 
-	if o.env == nil {
-		o.env = make(PreparedEnv, 1)
-	}
-
-	o.env["FRANKENPHP_WORKER\x00"] = "1"
-
 	// Check if a worker with the same fileName and moduleID already exists
 	if existingWorkers, ok := workers[absFileName]; ok {
 		for _, existingWorker := range existingWorkers {
@@ -94,6 +88,12 @@ func newWorker(o workerOpt) (*worker, error) {
 		}
 	}
 
+	if o.env == nil {
+		o.env = make(PreparedEnv, 1)
+	}
+
+	o.env["FRANKENPHP_WORKER\x00"] = "1"
+
 	w := &worker{
 		name:        o.name,
 		fileName:    absFileName,