symfony
diff --git a/‎src/Symfony/Component/Cache/Traits/ContractsTrait.php
Lines changed: 11 additions & 7 deletions b/‎src/Symfony/Component/Cache/Traits/ContractsTrait.php
Lines changed: 11 additions & 7 deletions
@@ -23,7 +23,7 @@
  *
  * @author Nicolas Grekas <p@tchwork.com>
  */
-class LockRegistry
+final class LockRegistry
 {
     private static $openedFiles = [];
     private static $lockedFiles = [];
@@ -74,7 +74,7 @@ public static function setFiles(array $files): array
         return $previousFiles;
     }
 
-    public static function compute(callable $callback, ItemInterface $item, bool &$save, CacheInterface $pool)
+    public static function compute(callable $callback, ItemInterface $item, bool &$save, CacheInterface $pool, \Closure $setMetadata = null)
     {
         $key = self::$files ? crc32($item->getKey()) % \count(self::$files) : -1;
 
@@ -88,7 +88,18 @@ public static function compute(callable $callback, ItemInterface $item, bool &$s
                 if (flock($lock, LOCK_EX | LOCK_NB)) {
                     self::$lockedFiles[$key] = true;
 
-                    return $callback($item, $save);
+                    $value = $callback($item, $save);
+
+                    if ($save) {
+                        if ($setMetadata) {
+                            $setMetadata($item);
+                        }
+
+                        $pool->save($item->set($value));
+                        $save = false;
+                    }
+
+                    return $value;
                 }
                 // if we failed the race, retry locking in blocking mode to wait for the winner
                 flock($lock, LOCK_SH);
@@ -125,6 +136,6 @@ private static function open(int $key)
             restore_error_handler();
         }
 
-        self::$openedFiles[$key] = $h ?: @fopen(self::$files[$key], 'r');
+        return self::$openedFiles[$key] = $h ?: @fopen(self::$files[$key], 'r');
     }
 }
@@ -40,7 +40,7 @@ trait ContractsTrait
     public function setCallbackWrapper(?callable $callbackWrapper): callable
     {
         $previousWrapper = $this->callbackWrapper;
-        $this->callbackWrapper = $callbackWrapper ?? function (callable $callback, ItemInterface $item, bool &$save, CacheInterface $pool) {
+        $this->callbackWrapper = $callbackWrapper ?? function (callable $callback, ItemInterface $item, bool &$save, CacheInterface $pool, \Closure $setMetadata) {
             return $callback($item, $save);
         };
 
@@ -56,17 +56,19 @@ private function doGet(AdapterInterface $pool, string $key, callable $callback,
         static $setMetadata;
 
         $setMetadata = $setMetadata ?? \Closure::bind(
-            function (AdapterInterface $pool, ItemInterface $item, float $startTime) {
+            function (CacheItem $item, float $startTime, ?array &$metadata) {
                 if ($item->expiry > $endTime = microtime(true)) {
-                    $item->newMetadata[ItemInterface::METADATA_EXPIRY] = $item->expiry;
-                    $item->newMetadata[ItemInterface::METADATA_CTIME] = 1000 * (int) ($endTime - $startTime);
+                    $item->newMetadata[CacheItem::METADATA_EXPIRY] = $metadata[CacheItem::METADATA_EXPIRY] = $item->expiry;
+                    $item->newMetadata[CacheItem::METADATA_CTIME] = $metadata[CacheItem::METADATA_CTIME] = 1000 * (int) ($endTime - $startTime);
+                } else {
+                    unset($metadata[CacheItem::METADATA_EXPIRY], $metadata[CacheItem::METADATA_CTIME]);
                 }
             },
             null,
             CacheItem::class
         );
 
-        return $this->contractsGet($pool, $key, function (CacheItem $item, bool &$save) use ($pool, $callback, $setMetadata) {
+        return $this->contractsGet($pool, $key, function (CacheItem $item, bool &$save) use ($pool, $callback, $setMetadata, &$metadata) {
             // don't wrap nor save recursive calls
             if (null === $callbackWrapper = $this->callbackWrapper) {
                 $value = $callback($item, $save);
@@ -78,8 +80,10 @@ function (AdapterInterface $pool, ItemInterface $item, float $startTime) {
             $startTime = microtime(true);
 
             try {
-                $value = $callbackWrapper($callback, $item, $save, $pool);
-                $setMetadata($pool, $item, $startTime);
+                $value = $callbackWrapper($callback, $item, $save, $pool, function (CacheItem $item) use ($setMetadata, $startTime, &$metadata) {
+                    $setMetadata($item, $startTime, $metadata);
+                });
+                $setMetadata($item, $startTime, $metadata);
 
                 return $value;
             } finally {
Original file line number	Diff line number	Diff line change
`@@ -23,7 +23,7 @@`
`23`	`23`	`*`
`24`	`24`	`* @author Nicolas Grekas <p@tchwork.com>`
`25`	`25`	`*/`
`26`		`-class LockRegistry`
	`26`	`+final class LockRegistry`
`27`	`27`	`{`
`28`	`28`	`private static $openedFiles = [];`
`29`	`29`	`private static $lockedFiles = [];`
`@@ -74,7 +74,7 @@ public static function setFiles(array $files): array`
`74`	`74`	`return $previousFiles;`
`75`	`75`	`}`
`76`	`76`
`77`		`- public static function compute(callable $callback, ItemInterface $item, bool &$save, CacheInterface $pool)`
	`77`	`+ public static function compute(callable $callback, ItemInterface $item, bool &$save, CacheInterface $pool, \Closure $setMetadata = null)`
`78`	`78`	`{`
`79`	`79`	`$key = self::$files ? crc32($item->getKey()) % \count(self::$files) : -1;`
`80`	`80`
`@@ -88,7 +88,18 @@ public static function compute(callable $callback, ItemInterface $item, bool &$s`
`88`	`88`	`if (flock($lock, LOCK_EX \| LOCK_NB)) {`
`89`	`89`	`self::$lockedFiles[$key] = true;`
`90`	`90`
`91`		`- return $callback($item, $save);`
	`91`	`+ $value = $callback($item, $save);`
	`92`	`+`
	`93`	`+ if ($save) {`
	`94`	`+ if ($setMetadata) {`
	`95`	`+ $setMetadata($item);`
	`96`	`+ }`
	`97`	`+`
	`98`	`+ $pool->save($item->set($value));`
	`99`	`+ $save = false;`
	`100`	`+ }`
	`101`	`+`
	`102`	`+ return $value;`
`92`	`103`	`}`
`93`	`104`	`// if we failed the race, retry locking in blocking mode to wait for the winner`
`94`	`105`	`flock($lock, LOCK_SH);`
`@@ -125,6 +136,6 @@ private static function open(int $key)`
`125`	`136`	`restore_error_handler();`
`126`	`137`	`}`
`127`	`138`
`128`		`- self::$openedFiles[$key] = $h ?: @fopen(self::$files[$key], 'r');`
	`139`	`+ return self::$openedFiles[$key] = $h ?: @fopen(self::$files[$key], 'r');`
`129`	`140`	`}`
`130`	`141`	`}`