Processes configuration fixes

luzrain · Feb 10, 2024 · 6b34f7f · 6b34f7f
1 parent 1cde1a4
commit 6b34f7f
Show file tree

Hide file tree

Showing 4 changed files with 8 additions and 6 deletions.
diff --git a/src/Runner.php b/src/Runner.php
@@ -62,7 +62,7 @@ public function run(): int
                 group: $config['group'],
                 name: $processConfig['name'],
                 command: $processConfig['command'],
-                processes: $processConfig['processes'],
+                count: $processConfig['count'],
             ));
         }
 

diff --git a/src/Worker/ProcessWorker.php b/src/Worker/ProcessWorker.php
@@ -18,11 +18,11 @@ public function __construct(
         string|null $group,
         string|null $name,
         private readonly string $command,
-        int $processes,
+        int $count,
     ) {
         parent::__construct(
             name: $name ?? $command,
-            count: $processes,
+            count: $count,
             user: $user,
             group: $group,
             onStart: $this->onStart(...),

diff --git a/src/Worker/SchedulerWorker.php b/src/Worker/SchedulerWorker.php
@@ -138,9 +138,7 @@ private function runSymfonyCommand(Application $application, string $command): i
         }
 
         // Execute in a forked process
-        $identifiers = $this->getEventLoop()->getIdentifiers();
-        \array_walk($identifiers, $this->getEventLoop()->disable(...));
-        $this->getEventLoop()->stop();
+        $this->detach();
         \cli_set_process_title($command);
         \pcntl_signal(SIGINT, SIG_IGN);
 

diff --git a/src/config/configuration.php b/src/config/configuration.php
@@ -96,6 +96,10 @@
                             ->isRequired()
                             ->cannotBeEmpty()
                             ->end()
+                        ->integerNode('count')
+                            ->info('Processes count')
+                            ->defaultValue(1)
+                            ->end()
                         ->end()
                     ->end()
                 ->end()