*/ private array $pending = []; private int $exitcode = -1; /** @var array */ private array $workers = []; /** @var array */ private array $batches = []; /** @var list */ private array $unexpectedOutputFiles = []; /** @var list */ private array $testresultFiles = []; /** @var list */ private array $coverageFiles = []; /** @var list */ private array $junitFiles = []; /** @var list */ private array $teamcityFiles = []; /** @var list */ private array $testdoxFiles = []; /** @var non-empty-string[] */ private readonly array $parameters; private CodeCoverageFilterRegistry $codeCoverageFilterRegistry; public function __construct( private readonly Options $options, private readonly OutputInterface $output ) { $this->printer = new ResultPrinter($output, $options); $this->timer = new Timer(); $wrapper = realpath( dirname(__DIR__, 4).DIRECTORY_SEPARATOR.'bin'.DIRECTORY_SEPARATOR.'worker.php', ); assert($wrapper !== false); $phpFinder = new PhpExecutableFinder(); $phpBin = $phpFinder->find(false); assert($phpBin !== false); $parameters = [$phpBin]; $parameters = array_merge($parameters, $phpFinder->findArguments()); if ($options->passthruPhp !== null) { $parameters = array_merge($parameters, $options->passthruPhp); } $parameters[] = $wrapper; $this->parameters = $parameters; $this->codeCoverageFilterRegistry = new CodeCoverageFilterRegistry(); } public function run(): int { $directory = dirname(__DIR__); assert($directory !== ''); ExcludeList::addDirectory($directory); TestResultFacade::init(); EventFacade::instance()->seal(); $suiteLoader = new SuiteLoader( $this->options, $this->output, $this->codeCoverageFilterRegistry, ); $this->pending = $this->getTestFiles($suiteLoader); $result = TestResultFacade::result(); $this->timer->start(); $this->startWorkers(); $this->assignAllPendingTests(); $this->waitForAllToFinish(); return $this->complete($result); } private function startWorkers(): void { for ($token = 1; $token <= $this->options->processes; $token++) { $this->startWorker($token); } } private function assignAllPendingTests(): void { $batchSize = $this->options->maxBatchSize; while (count($this->pending) > 0 && count($this->workers) > 0) { foreach ($this->workers as $token => $worker) { if (! $worker->isRunning()) { throw $worker->getWorkerCrashedException(); } if (! $worker->isFree()) { continue; } $this->flushWorker($worker); if ($batchSize !== 0 && $this->batches[$token] === $batchSize) { $this->destroyWorker($token); $worker = $this->startWorker($token); } if ( $this->exitcode > 0 && $this->options->configuration->stopOnFailure() ) { $this->pending = []; } elseif (($pending = array_shift($this->pending)) !== null) { $worker->assign($pending); $this->batches[$token]++; } } usleep(self::CYCLE_SLEEP); } } private function flushWorker(WrapperWorker $worker): void { $this->exitcode = max($this->exitcode, $worker->getExitCode()); $this->printer->printFeedback( $worker->progressFile, $worker->unexpectedOutputFile, $this->teamcityFiles, ); $worker->reset(); } private function waitForAllToFinish(): void { $stopped = []; while (count($this->workers) > 0) { foreach ($this->workers as $index => $worker) { if ($worker->isRunning()) { if (! isset($stopped[$index]) && $worker->isFree()) { $worker->stop(); $stopped[$index] = true; } continue; } if (! $worker->isFree()) { throw $worker->getWorkerCrashedException(); } $this->flushWorker($worker); unset($this->workers[$index]); } usleep(self::CYCLE_SLEEP); } } /** @param positive-int $token */ private function startWorker(int $token): WrapperWorker { $worker = new WrapperWorker( $this->output, $this->options, $this->parameters, $token, ); $worker->start(); $this->batches[$token] = 0; $this->unexpectedOutputFiles[] = $worker->unexpectedOutputFile; $this->testresultFiles[] = $worker->testresultFile; if (isset($worker->junitFile)) { $this->junitFiles[] = $worker->junitFile; } if (isset($worker->coverageFile)) { $this->coverageFiles[] = $worker->coverageFile; } if (isset($worker->teamcityFile)) { $this->teamcityFiles[] = $worker->teamcityFile; } if (isset($worker->testdoxFile)) { $this->testdoxFiles[] = $worker->testdoxFile; } return $this->workers[$token] = $worker; } private function destroyWorker(int $token): void { $this->workers[$token]->stop(); // We need to wait for ApplicationForWrapperWorker::end to end while ($this->workers[$token]->isRunning()) { usleep(self::CYCLE_SLEEP); } unset($this->workers[$token]); } private function complete(TestResult $testResultSum): int { foreach ($this->testresultFiles as $testresultFile) { if (! $testresultFile->isFile()) { continue; } $contents = file_get_contents($testresultFile->getPathname()); assert($contents !== false); $testResult = unserialize($contents); assert($testResult instanceof TestResult); $testResultSum = new TestResult( (int) $testResultSum->hasTests() + (int) $testResult->hasTests(), $testResultSum->numberOfTestsRun() + $testResult->numberOfTestsRun(), $testResultSum->numberOfAssertions() + $testResult->numberOfAssertions(), array_merge_recursive($testResultSum->testErroredEvents(), $testResult->testErroredEvents()), array_merge_recursive($testResultSum->testFailedEvents(), $testResult->testFailedEvents()), array_merge_recursive($testResultSum->testConsideredRiskyEvents(), $testResult->testConsideredRiskyEvents()), array_merge_recursive($testResultSum->testSuiteSkippedEvents(), $testResult->testSuiteSkippedEvents()), array_merge_recursive($testResultSum->testSkippedEvents(), $testResult->testSkippedEvents()), array_merge_recursive($testResultSum->testMarkedIncompleteEvents(), $testResult->testMarkedIncompleteEvents()), array_merge_recursive($testResultSum->testTriggeredPhpunitDeprecationEvents(), $testResult->testTriggeredPhpunitDeprecationEvents()), array_merge_recursive($testResultSum->testTriggeredPhpunitErrorEvents(), $testResult->testTriggeredPhpunitErrorEvents()), array_merge_recursive($testResultSum->testTriggeredPhpunitWarningEvents(), $testResult->testTriggeredPhpunitWarningEvents()), array_merge_recursive($testResultSum->testRunnerTriggeredDeprecationEvents(), $testResult->testRunnerTriggeredDeprecationEvents()), array_merge_recursive($testResultSum->testRunnerTriggeredWarningEvents(), $testResult->testRunnerTriggeredWarningEvents()), array_merge_recursive($testResultSum->errors(), $testResult->errors()), array_merge_recursive($testResultSum->deprecations(), $testResult->deprecations()), array_merge_recursive($testResultSum->notices(), $testResult->notices()), array_merge_recursive($testResultSum->warnings(), $testResult->warnings()), array_merge_recursive($testResultSum->phpDeprecations(), $testResult->phpDeprecations()), array_merge_recursive($testResultSum->phpNotices(), $testResult->phpNotices()), array_merge_recursive($testResultSum->phpWarnings(), $testResult->phpWarnings()), $testResultSum->numberOfIssuesIgnoredByBaseline() + $testResult->numberOfIssuesIgnoredByBaseline(), ); } $testResultSum = new TestResult( ResultReflection::numberOfTests($testResultSum), $testResultSum->numberOfTestsRun(), $testResultSum->numberOfAssertions(), $testResultSum->testErroredEvents(), $testResultSum->testFailedEvents(), $testResultSum->testConsideredRiskyEvents(), $testResultSum->testSuiteSkippedEvents(), $testResultSum->testSkippedEvents(), $testResultSum->testMarkedIncompleteEvents(), $testResultSum->testTriggeredPhpunitDeprecationEvents(), $testResultSum->testTriggeredPhpunitErrorEvents(), $testResultSum->testTriggeredPhpunitWarningEvents(), $testResultSum->testRunnerTriggeredDeprecationEvents(), array_values(array_filter( $testResultSum->testRunnerTriggeredWarningEvents(), fn (WarningTriggered $event): bool => ! str_contains($event->message(), 'No tests found') )), $testResultSum->errors(), $testResultSum->deprecations(), $testResultSum->notices(), $testResultSum->warnings(), $testResultSum->phpDeprecations(), $testResultSum->phpNotices(), $testResultSum->phpWarnings(), $testResultSum->numberOfIssuesIgnoredByBaseline(), ); $this->printer->printResults( $testResultSum, $this->teamcityFiles, $this->testdoxFiles, $this->timer->stop(), ); $this->generateCodeCoverageReports(); $this->generateLogs(); $exitcode = Result::exitCode($this->options->configuration, $testResultSum); $this->clearFiles($this->unexpectedOutputFiles); $this->clearFiles($this->testresultFiles); $this->clearFiles($this->coverageFiles); $this->clearFiles($this->junitFiles); $this->clearFiles($this->teamcityFiles); $this->clearFiles($this->testdoxFiles); return $exitcode; } private function generateCodeCoverageReports(): void { if ($this->coverageFiles === []) { return; } $coverageManager = new CodeCoverage(); $coverageManager->init( $this->options->configuration, $this->codeCoverageFilterRegistry, false, ); if (! $coverageManager->isActive()) { $this->output->writeln([ '', ' WARN No code coverage driver is available.', '', ]); return; } $coverageMerger = new CoverageMerger($coverageManager->codeCoverage()); foreach ($this->coverageFiles as $coverageFile) { $coverageMerger->addCoverageFromFile($coverageFile); } $coverageManager->generateReports( $this->printer->printer, $this->options->configuration, ); } private function generateLogs(): void { if ($this->junitFiles === []) { return; } $testSuite = (new LogMerger())->merge($this->junitFiles); (new Writer())->write( $testSuite, $this->options->configuration->logfileJunit(), ); } /** @param list $files */ private function clearFiles(array $files): void { foreach ($files as $file) { if (! $file->isFile()) { continue; } unlink($file->getPathname()); } } /** * Returns the test files to be executed. * * @return array */ private function getTestFiles(SuiteLoader $suiteLoader): array { /** @var array $files */ $files = [ ...array_values(array_filter( $suiteLoader->tests, fn (string $filename): bool => ! str_ends_with($filename, "eval()'d code") )), ...TestSuite::getInstance()->tests->getFilenames(), ]; return $files; // @phpstan-ignore-line } }