Debugging messages for parallel analysis

Author: ondrejmirtes

src/Command/AnalyseApplication.php

@@ -189,7 +189,7 @@ private function runAnalyser(
 			$postFileCallback = null;
 		}
 
-		$analyserResult = $this->analyserRunner->runAnalyser($files, $allAnalysedFiles, $preFileCallback, $postFileCallback, $debug, true, $projectConfigFile, null, null, $input);
+		$analyserResult = $this->analyserRunner->runAnalyser($files, $allAnalysedFiles, $preFileCallback, $postFileCallback, $debug, true, $projectConfigFile, null, null, $input, $errorOutput);
 
 		if (isset($progressStarted) && $progressStarted) {
 			$errorOutput->getStyle()->progressFinish();

src/Command/AnalyserRunner.php

@@ -57,7 +57,8 @@ public function runAnalyser(
 		?string $projectConfigFile,
 		?string $tmpFile,
 		?string $insteadOfFile,
-		InputInterface $input
+		InputInterface $input,
+		Output $output
 	): AnalyserResult
 	{
 		$filesCount = count($files);
@@ -71,13 +72,17 @@ public function runAnalyser(
 			$mainScript = $_SERVER['argv'][0];
 		}
 
+		if ($output->isDebug()) {
+			$output->writeLineFormatted(sprintf('Schedule: %d processes, %d jobs', $schedule->getNumberOfProcesses(), count($schedule->getJobs())));
+		}
+
 		if (
 			!$debug
 			&& $allowParallel
 			&& $mainScript !== null
 			&& $schedule->getNumberOfProcesses() > 1
 		) {
-			return $this->parallelAnalyser->analyse($schedule, $mainScript, $postFileCallback, $projectConfigFile, $tmpFile, $insteadOfFile, $input);
+			return $this->parallelAnalyser->analyse($schedule, $mainScript, $postFileCallback, $projectConfigFile, $tmpFile, $insteadOfFile, $input, $output);
 		}
 
 		return $this->analyser->analyse(

src/Command/FixerWorkerCommand.php

@@ -154,7 +154,8 @@ protected function execute(InputInterface $input, OutputInterface $output): int
 			$configuration,
 			$tmpFile,
 			$insteadOfFile,
-			$input
+			$input,
+			$inceptionResult->getErrorOutput()
 		);
 		$result = $resultCacheManager->process(
 			$this->switchTmpFileInAnalyserResult($intermediateAnalyserResult, $tmpFile, $insteadOfFile),

src/Parallel/ParallelAnalyser.php

@@ -7,6 +7,7 @@
 use Nette\Utils\Random;
 use PHPStan\Analyser\AnalyserResult;
 use PHPStan\Analyser\Error;
+use PHPStan\Command\Output;
 use PHPStan\Dependency\ExportedNode;
 use PHPStan\Process\ProcessHelper;
 use React\EventLoop\StreamSelectLoop;
@@ -52,7 +53,8 @@ public function analyse(
 		?string $projectConfigFile,
 		?string $tmpFile,
 		?string $insteadOfFile,
-		InputInterface $input
+		InputInterface $input,
+		Output $errorOutput
 	): AnalyserResult
 	{
 		$jobs = array_reverse($schedule->getJobs());
@@ -131,7 +133,7 @@ public function analyse(
 				$commandOptions,
 				$input
 			), $loop, $this->processTimeout);
-			$process->start(function (array $json) use ($process, &$internalErrors, &$errors, &$dependencies, &$exportedNodes, &$jobs, $postFileCallback, &$internalErrorsCount, &$reachedInternalErrorsCountLimit, $processIdentifier): void {
+			$process->start(function (array $json) use ($process, &$internalErrors, &$errors, &$dependencies, &$exportedNodes, &$jobs, $postFileCallback, &$internalErrorsCount, &$reachedInternalErrorsCountLimit, $processIdentifier, $errorOutput): void {
 				foreach ($json['errors'] as $jsonError) {
 					if (is_string($jsonError)) {
 						$internalErrors[] = sprintf('Internal error: %s', $jsonError);
@@ -175,14 +177,24 @@ public function analyse(
 				}
 
 				if (count($jobs) === 0) {
+					if ($errorOutput->isDebug()) {
+						$errorOutput->writeLineFormatted(sprintf('Process %s ended successfully - no more jobs remaining.', $processIdentifier));
+					}
 					$this->processPool->quitProcess($processIdentifier);
 					return;
 				}
 
+				if ($errorOutput->isDebug()) {
+					$errorOutput->writeLineFormatted(sprintf('Process %s analysis successful - queueing a new job.', $processIdentifier));
+				}
+
 				$job = array_pop($jobs);
 				$process->request(['action' => 'analyse', 'files' => $job]);
-			}, $handleError, function ($exitCode, string $output) use (&$internalErrors, &$internalErrorsCount, $processIdentifier): void {
+			}, $handleError, function ($exitCode, $termSignal, string $output) use (&$internalErrors, &$internalErrorsCount, $processIdentifier, $errorOutput): void {
 				$this->processPool->tryQuitProcess($processIdentifier);
+				if ($errorOutput->isDebug()) {
+					$errorOutput->writeLineFormatted(sprintf('Process %s exited - exit code %s, term signal %s, output: %s', $processIdentifier, $exitCode ?? 'null', $termSignal ?? 'null', $output));
+				}
 				if ($exitCode === 0) {
 					return;
 				}

src/Parallel/Process.php

@@ -48,7 +48,7 @@ public function __construct(
 	/**
 	 * @param callable(mixed[] $json) : void $onData
 	 * @param callable(\Throwable $exception) : void $onError
-	 * @param callable(?int $exitCode, string $output) : void $onExit
+	 * @param callable(?int $exitCode, ?int $termSignal, string $output) : void $onExit
 	 */
 	public function start(callable $onData, callable $onError, callable $onExit): void
 	{
@@ -69,7 +69,7 @@ public function start(callable $onData, callable $onError, callable $onExit): vo
 		$this->process->start($this->loop);
 		$this->onData = $onData;
 		$this->onError = $onError;
-		$this->process->on('exit', function ($exitCode) use ($onExit): void {
+		$this->process->on('exit', function ($exitCode, $termSignal) use ($onExit): void {
 			$this->cancelTimer();
 
 			$output = '';
@@ -84,7 +84,7 @@ public function start(callable $onData, callable $onError, callable $onExit): vo
 			if (is_string($stdErr)) {
 				$output .= $stdErr;
 			}
-			$onExit($exitCode, $output);
+			$onExit($exitCode, $termSignal, $output);
 			fclose($this->stdOut);
 			fclose($this->stdErr);
 		});