Support cache in parallel analysis

Cache check is done during file iteration - if file is in cache and wasn't changed, then it's skip by iterator and doesn't even go to the worker. That's why `ReadonlyCacheManager` used on worker's side is a bit superfluous, but I thought it's safer to use it instead of `NullCacheManager`.

Anyway, each file is stored to cache when worker reports analysis result to the parallelisation operator, so it's basically similar to sequential analysis, because file write is done only in one process.

src/Console/Command/WorkerCommand.php

@@ -21,6 +21,7 @@
 use PhpCsFixer\Error\ErrorsManager;
 use PhpCsFixer\FixerFileProcessedEvent;
 use PhpCsFixer\Runner\Parallel\ParallelConfig;
+use PhpCsFixer\Runner\Parallel\ReadonlyCacheManager;
 use PhpCsFixer\Runner\Runner;
 use PhpCsFixer\ToolInfoInterface;
 use React\EventLoop\StreamSelectLoop;
@@ -50,6 +51,7 @@ final class WorkerCommand extends Command
  private ConfigurationResolver $configurationResolver;
  private ErrorsManager $errorsManager;
  private EventDispatcherInterface $eventDispatcher;
+ private ReadonlyCacheManager $readonlyCacheManager;
 
  /** @var array<int, FixerFileProcessedEvent> */
  private array $events;
@@ -220,6 +222,8 @@ private function createRunner(InputInterface $input): Runner
  $this->toolInfo
  );
 
+ $this->readonlyCacheManager = new ReadonlyCacheManager($this->configurationResolver->getCacheManager());
+
  return new Runner(
  null, // Paths are known when parallelisation server requests new chunk, not now
  $this->configurationResolver->getFixers(),
@@ -228,7 +232,7 @@ private function createRunner(InputInterface $input): Runner
  $this->errorsManager,
  $this->configurationResolver->getLinter(),
  $this->configurationResolver->isDryRun(),
- $this->configurationResolver->getCacheManager(),
+ $this->readonlyCacheManager,
  $this->configurationResolver->getDirectory(),
  $this->configurationResolver->shouldStopOnViolation(),
  ParallelConfig::sequential(), // IMPORTANT! Worker must run in sequential mode

src/Runner/Parallel/ReadonlyCacheManager.php

@@ -0,0 +1,34 @@
+<?php
+
+declare(strict_types=1);
+
+/*
+ * This file is part of PHP CS Fixer.
+ *
+ * (c) Fabien Potencier <[email protected]>
+ * Dariusz Rumiński <[email protected]>
+ *
+ * This source file is subject to the MIT license that is bundled
+ * with this source code in the file LICENSE.
+ */
+
+namespace PhpCsFixer\Runner\Parallel;
+
+use PhpCsFixer\Cache\CacheManagerInterface;
+
+final class ReadonlyCacheManager implements CacheManagerInterface
+{
+ private CacheManagerInterface $cacheManager;
+
+ public function __construct(CacheManagerInterface $cacheManager)
+ {
+ $this->cacheManager = $cacheManager;
+ }
+
+ public function needFixing(string $file, string $fileContent): bool
+ {
+ return $this->cacheManager->needFixing($file, $fileContent);
+ }
+
+ public function setFile(string $file, string $fileContent): void {}
+}

src/Runner/Runner.php

@@ -230,6 +230,7 @@ function (array $analysisResult) use ($processPool, $process, $identifier, $file
  }
  // Dispatch an event for each file processed and dispatch its status (required for progress output)
  $this->dispatchEvent(FixerFileProcessedEvent::NAME, new FixerFileProcessedEvent($result['status']));
+ $this->cacheManager->setFile($file, file_get_contents($this->directory->getAbsolutePath().\DIRECTORY_SEPARATOR.$file));
 
  foreach ($result['errors'] ?? [] as $workerError) {
  $error = new Error(