feat: add parallel cache support

doc/usage.rst

@@ -142,6 +142,7 @@ Note: You need to pass the config to the ``fix`` command, in order to make it wo
 
 .. code-block:: console
 
+    export PHP_CS_FIXER_EXPERIMENTAL_PARALLEL_CACHE=1
     php php-cs-fixer.phar list-files --config=.php-cs-fixer.dist.php | xargs -n 10 -P 8 php php-cs-fixer.phar fix --config=.php-cs-fixer.dist.php --path-mode intersection -v
 
 * ``-n`` defines how many files a single subprocess process

src/Cache/Cache.php

@@ -136,4 +136,18 @@ public static function fromJson(string $json): self
 
         return $cache;
     }
+
+    /**
+     * @internal
+     */
+    public function backfillHashes(self $oldCache): bool
+    {
+        if (!$this->getSignature()->equals($oldCache->getSignature())) {
+            return false;
+        }
+
+        $this->hashes = array_merge($oldCache->hashes, $this->hashes);
+
+        return true;
+    }
 }

src/Cache/FileHandler.php

@@ -25,6 +25,8 @@
 {
     private string $file;
 
+    private int $fileLastModification = 0;
+
     public function __construct(string $file)
     {
         $this->file = $file;
@@ -41,21 +43,86 @@
             return null;
         }
 
-        $content = file_get_contents($this->file);
-
-        try {
-            $cache = Cache::fromJson($content);
-        } catch (\InvalidArgumentException $exception) {
+        $handle = fopen($this->file, 'r');
+        if (false === $handle) {
             return null;
         }
 
+        $cache = $this->readFromHandle($handle);
+        $this->fileLastModification = $this->getFileLastUpdate($handle);
+        var_dump("\n".getmypid().' !!! FRS !!! READ '.$this->fileLastModification);
+        fclose($handle);
+
         return $cache;
     }
 
     public function write(CacheInterface $cache): void
     {
-        $content = $cache->toJson();
+        $this->ensureFileIsWriteable();
+
+        $handle = fopen($this->file, 'r+');
+        if (false === $handle) {
+            return;
+        }
+
+        $actualLastModification = $this->getFileLastUpdate($handle);
+
+        var_dump("\n".getmypid().' !!! FRS !!! DECISION ???');
+        var_dump([
+            'property' => $this->fileLastModification,
+            'os' => $actualLastModification,
+            'should backfill' => $this->fileLastModification < $actualLastModification,
+        ]);
+
+        if ($this->fileLastModification < $actualLastModification) {
+            flock($handle, LOCK_EX);
+
+            $oldCache = $this->readFromHandle($handle);
+            rewind($handle);
+
+            if ($oldCache && method_exists($cache, 'backfillHashes')) {
+                var_dump("\n".getmypid().' !!! FRS !!! BACKFILL');
+                $cache->backfillHashes($oldCache);
+            }
+        }
+        var_dump("\n".getmypid().' !!! FRS !!! SAVE FILE');
+        ftruncate($handle, 0);
+        fwrite($handle, $cache->toJson());
+        fflush($handle);
+        fsync($handle);
+
+        var_dump("\n".getmypid().' !!! FRS !!! AFTER SAVE '.$this->getFileLastUpdate($handle));
+        fclose($handle);
+    }
+
+    private function getFileLastUpdate($handle): int
+    {
+        clearstatcache(true, $this->file);
 
+        return fstat($handle)['mtime'] ?: 0;
+    }
+
+    /**
+     * @param resource $handle
+     */
+    private function readFromHandle($handle): ?CacheInterface
+    {
+        try {
+            $size = filesize($this->file);
+            if (!$size) {
+                return null;
+            }
+
+            $content = fread($handle, $size);
+
+            return Cache::fromJson($content);
+        } catch (\InvalidArgumentException $exception) {
+            return null;
+        }
+    }
+
+    private function ensureFileIsWriteable(): void
+    {
         if (file_exists($this->file)) {
             if (is_dir($this->file)) {
                 throw new IOException(
@@ -95,18 +162,5 @@
             @touch($this->file);
             @chmod($this->file, 0666);
         }
-
-        $bytesWritten = @file_put_contents($this->file, $content);
-
-        if (false === $bytesWritten) {
-            $error = error_get_last();
-
-            throw new IOException(
-                sprintf('Failed to write file "%s", "%s".', $this->file, $error['message'] ?? 'no reason available'),
-                0,
-                null,
-                $this->file
-            );
-        }
     }
 }