vendor/symfony/cache-contracts/CacheTrait.php line 35

Open in your IDE?
  1. <?php
  3. /*
  4.  * This file is part of the Symfony package.
  5.  *
  6.  * (c) Fabien Potencier <fabien@symfony.com>
  7.  *
  8.  * For the full copyright and license information, please view the LICENSE
  9.  * file that was distributed with this source code.
  10.  */
  12. namespace Symfony\Contracts\Cache;
  14. use Psr\Cache\CacheItemPoolInterface;
  15. use Psr\Cache\InvalidArgumentException;
  16. use Psr\Log\LoggerInterface;
  18. // Help opcache.preload discover always-needed symbols
  19. class_exists(InvalidArgumentException::class);
  21. /**
  22.  * An implementation of CacheInterface for PSR-6 CacheItemPoolInterface classes.
  23.  *
  24.  * @author Nicolas Grekas <p@tchwork.com>
  25.  */
  26. trait CacheTrait
  27. {
  28.     /**
  29.      * {@inheritdoc}
  30.      *
  31.      * @return mixed
  32.      */
  33.     public function get(string $key, callable $callback, float $beta = null, array &$metadata = null)
  34.     {
  35.         return $this->doGet($this, $key, $callback, $beta, $metadata);
  36.     }
  38.     /**
  39.      * {@inheritdoc}
  40.      */
  41.     public function delete(string $key): bool
  42.     {
  43.         return $this->deleteItem($key);
  44.     }
  46.     private function doGet(CacheItemPoolInterface $pool, string $key, callable $callback, ?float $beta, array &$metadata = null, LoggerInterface $logger = null)
  47.     {
  48.         if (0 > $beta = $beta ?? 1.0) {
  49.             throw new class(sprintf('Argument "$beta" provided to "%s::get()" must be a positive number, %f given.', static::class, $beta)) extends \InvalidArgumentException implements InvalidArgumentException { };
  50.         }
  52.         $item = $pool->getItem($key);
  53.         $recompute = !$item->isHit() || \INF === $beta;
  54.         $metadata = $item instanceof ItemInterface ? $item->getMetadata() : [];
  56.         if (!$recompute && $metadata) {
  57.             $expiry = $metadata[ItemInterface::METADATA_EXPIRY] ?? false;
  58.             $ctime = $metadata[ItemInterface::METADATA_CTIME] ?? false;
  60.             if ($recompute = $ctime && $expiry && $expiry <= ($now = microtime(true)) - $ctime / 1000 * $beta * log(random_int(1, \PHP_INT_MAX) / \PHP_INT_MAX)) {
  61.                 // force applying defaultLifetime to expiry
  62.                 $item->expiresAt(null);
  63.                 $logger && $logger->info('Item "{key}" elected for early recomputation {delta}s before its expiration', [
  64.                     'key' => $key,
  65.                     'delta' => sprintf('%.1f', $expiry - $now),
  66.                 ]);
  67.             }
  68.         }
  70.         if ($recompute) {
  71.             $save = true;
  72.             $item->set($callback($item, $save));
  73.             if ($save) {
  74.                 $pool->save($item);
  75.             }
  76.         }
  78.         return $item->get();
  79.     }
  80. }