-
Notifications
You must be signed in to change notification settings - Fork 433
/
AnalyserRunner.php
117 lines (102 loc) · 2.82 KB
/
AnalyserRunner.php
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
<?php declare(strict_types = 1);
namespace PHPStan\Command;
use PHPStan\Analyser\Analyser;
use PHPStan\Analyser\AnalyserResult;
use PHPStan\Parallel\ParallelAnalyser;
use PHPStan\Parallel\Scheduler;
use PHPStan\Process\CpuCoreCounter;
use Symfony\Component\Console\Input\InputInterface;
class AnalyserRunner
{
private Scheduler $scheduler;
private Analyser $analyser;
private ParallelAnalyser $parallelAnalyser;
private CpuCoreCounter $cpuCoreCounter;
public function __construct(
Scheduler $scheduler,
Analyser $analyser,
ParallelAnalyser $parallelAnalyser,
CpuCoreCounter $cpuCoreCounter
)
{
$this->scheduler = $scheduler;
$this->analyser = $analyser;
$this->parallelAnalyser = $parallelAnalyser;
$this->cpuCoreCounter = $cpuCoreCounter;
}
/**
* @param string[] $files
* @param string[] $allAnalysedFiles
* @param \Closure|null $preFileCallback
* @param \Closure|null $postFileCallback
* @param bool $debug
* @param bool $allowParallel
* @param string|null $projectConfigFile
* @param string|null $tmpFile
* @param string|null $insteadOfFile
* @param InputInterface $input
* @return AnalyserResult
* @throws \Throwable
*/
public function runAnalyser(
array $files,
array $allAnalysedFiles,
?\Closure $preFileCallback,
?\Closure $postFileCallback,
bool $debug,
bool $allowParallel,
?string $projectConfigFile,
?string $tmpFile,
?string $insteadOfFile,
InputInterface $input
): AnalyserResult
{
$filesCount = count($files);
if ($filesCount === 0) {
return new AnalyserResult([], [], [], [], false);
}
$schedule = $this->scheduler->scheduleWork($this->cpuCoreCounter->getNumberOfCpuCores(), $files);
$mainScript = null;
if (isset($_SERVER['argv'][0]) && file_exists($_SERVER['argv'][0])) {
$mainScript = $_SERVER['argv'][0];
}
if (
!$debug
&& $allowParallel
&& $mainScript !== null
&& $schedule->getNumberOfProcesses() > 1
) {
return $this->parallelAnalyser->analyse($schedule, $mainScript, $postFileCallback, $projectConfigFile, $tmpFile, $insteadOfFile, $input);
}
return $this->analyser->analyse(
$this->switchTmpFile($files, $insteadOfFile, $tmpFile),
$preFileCallback,
$postFileCallback,
$debug,
$this->switchTmpFile($allAnalysedFiles, $insteadOfFile, $tmpFile)
);
}
/**
* @param string[] $analysedFiles
* @param string|null $insteadOfFile
* @param string|null $tmpFile
* @return string[]
*/
private function switchTmpFile(
array $analysedFiles,
?string $insteadOfFile,
?string $tmpFile
): array
{
$analysedFiles = array_values(array_filter($analysedFiles, static function (string $file) use ($insteadOfFile): bool {
if ($insteadOfFile === null) {
return true;
}
return $file !== $insteadOfFile;
}));
if ($tmpFile !== null) {
$analysedFiles[] = $tmpFile;
}
return $analysedFiles;
}
}