vendor/symfony/cache/LockRegistry.php line 85

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\Component\Cache;
  14. use Psr\Log\LoggerInterface;
  15. use Symfony\Contracts\Cache\CacheInterface;
  16. use Symfony\Contracts\Cache\ItemInterface;
  18. /**
  19.  * LockRegistry is used internally by existing adapters to protect against cache stampede.
  20.  *
  21.  * It does so by wrapping the computation of items in a pool of locks.
  22.  * Foreach each apps, there can be at most 20 concurrent processes that
  23.  * compute items at the same time and only one per cache-key.
  24.  *
  25.  * @author Nicolas Grekas <p@tchwork.com>
  26.  */
  27. final class LockRegistry
  28. {
  29.     private static $openedFiles = [];
  30.     private static $lockedFiles;
  32.     /**
  33.      * The number of items in this list controls the max number of concurrent processes.
  34.      */
  35.     private static $files = [
  36.         __DIR__.\DIRECTORY_SEPARATOR.'Adapter'.\DIRECTORY_SEPARATOR.'AbstractAdapter.php',
  37.         __DIR__.\DIRECTORY_SEPARATOR.'Adapter'.\DIRECTORY_SEPARATOR.'AbstractTagAwareAdapter.php',
  38.         __DIR__.\DIRECTORY_SEPARATOR.'Adapter'.\DIRECTORY_SEPARATOR.'AdapterInterface.php',
  39.         __DIR__.\DIRECTORY_SEPARATOR.'Adapter'.\DIRECTORY_SEPARATOR.'ApcuAdapter.php',
  40.         __DIR__.\DIRECTORY_SEPARATOR.'Adapter'.\DIRECTORY_SEPARATOR.'ArrayAdapter.php',
  41.         __DIR__.\DIRECTORY_SEPARATOR.'Adapter'.\DIRECTORY_SEPARATOR.'ChainAdapter.php',
  42.         __DIR__.\DIRECTORY_SEPARATOR.'Adapter'.\DIRECTORY_SEPARATOR.'CouchbaseBucketAdapter.php',
  43.         __DIR__.\DIRECTORY_SEPARATOR.'Adapter'.\DIRECTORY_SEPARATOR.'CouchbaseCollectionAdapter.php',
  44.         __DIR__.\DIRECTORY_SEPARATOR.'Adapter'.\DIRECTORY_SEPARATOR.'DoctrineAdapter.php',
  45.         __DIR__.\DIRECTORY_SEPARATOR.'Adapter'.\DIRECTORY_SEPARATOR.'DoctrineDbalAdapter.php',
  46.         __DIR__.\DIRECTORY_SEPARATOR.'Adapter'.\DIRECTORY_SEPARATOR.'FilesystemAdapter.php',
  47.         __DIR__.\DIRECTORY_SEPARATOR.'Adapter'.\DIRECTORY_SEPARATOR.'FilesystemTagAwareAdapter.php',
  48.         __DIR__.\DIRECTORY_SEPARATOR.'Adapter'.\DIRECTORY_SEPARATOR.'MemcachedAdapter.php',
  49.         __DIR__.\DIRECTORY_SEPARATOR.'Adapter'.\DIRECTORY_SEPARATOR.'NullAdapter.php',
  50.         __DIR__.\DIRECTORY_SEPARATOR.'Adapter'.\DIRECTORY_SEPARATOR.'ParameterNormalizer.php',
  51.         __DIR__.\DIRECTORY_SEPARATOR.'Adapter'.\DIRECTORY_SEPARATOR.'PdoAdapter.php',
  52.         __DIR__.\DIRECTORY_SEPARATOR.'Adapter'.\DIRECTORY_SEPARATOR.'PhpArrayAdapter.php',
  53.         __DIR__.\DIRECTORY_SEPARATOR.'Adapter'.\DIRECTORY_SEPARATOR.'PhpFilesAdapter.php',
  54.         __DIR__.\DIRECTORY_SEPARATOR.'Adapter'.\DIRECTORY_SEPARATOR.'ProxyAdapter.php',
  55.         __DIR__.\DIRECTORY_SEPARATOR.'Adapter'.\DIRECTORY_SEPARATOR.'Psr16Adapter.php',
  56.         __DIR__.\DIRECTORY_SEPARATOR.'Adapter'.\DIRECTORY_SEPARATOR.'RedisAdapter.php',
  57.         __DIR__.\DIRECTORY_SEPARATOR.'Adapter'.\DIRECTORY_SEPARATOR.'RedisTagAwareAdapter.php',
  58.         __DIR__.\DIRECTORY_SEPARATOR.'Adapter'.\DIRECTORY_SEPARATOR.'TagAwareAdapter.php',
  59.         __DIR__.\DIRECTORY_SEPARATOR.'Adapter'.\DIRECTORY_SEPARATOR.'TagAwareAdapterInterface.php',
  60.         __DIR__.\DIRECTORY_SEPARATOR.'Adapter'.\DIRECTORY_SEPARATOR.'TraceableAdapter.php',
  61.         __DIR__.\DIRECTORY_SEPARATOR.'Adapter'.\DIRECTORY_SEPARATOR.'TraceableTagAwareAdapter.php',
  62.     ];
  64.     /**
  65.      * Defines a set of existing files that will be used as keys to acquire locks.
  66.      *
  67.      * @return array The previously defined set of files
  68.      */
  69.     public static function setFiles(array $files): array
  70.     {
  71.         $previousFiles = self::$files;
  72.         self::$files = $files;
  74.         foreach (self::$openedFiles as $file) {
  75.             if ($file) {
  76.                 flock($file, \LOCK_UN);
  77.                 fclose($file);
  78.             }
  79.         }
  80.         self::$openedFiles = self::$lockedFiles = [];
  82.         return $previousFiles;
  83.     }
  85.     public static function compute(callable $callback, ItemInterface $item, bool &$save, CacheInterface $pool, \Closure $setMetadata = null, LoggerInterface $logger = null)
  86.     {
  87.         if ('\\' === \DIRECTORY_SEPARATOR && null === self::$lockedFiles) {
  88.             // disable locking on Windows by default
  89.             self::$files = self::$lockedFiles = [];
  90.         }
  92.         $key = self::$files ? abs(crc32($item->getKey())) % \count(self::$files) : -1;
  94.         if ($key < 0 || self::$lockedFiles || !$lock = self::open($key)) {
  95.             return $callback($item, $save);
  96.         }
  98.         while (true) {
  99.             try {
  100.                 $locked = false;
  101.                 // race to get the lock in non-blocking mode
  102.                 $locked = flock($lock, \LOCK_EX | \LOCK_NB, $wouldBlock);
  104.                 if ($locked || !$wouldBlock) {
  105.                     $logger && $logger->info(sprintf('Lock %s, now computing item "{key}"', $locked ? 'acquired' : 'not supported'), ['key' => $item->getKey()]);
  106.                     self::$lockedFiles[$key] = true;
  108.                     $value = $callback($item, $save);
  110.                     if ($save) {
  111.                         if ($setMetadata) {
  112.                             $setMetadata($item);
  113.                         }
  115.                         $pool->save($item->set($value));
  116.                         $save = false;
  117.                     }
  119.                     return $value;
  120.                 }
  121.                 // if we failed the race, retry locking in blocking mode to wait for the winner
  122.                 $logger && $logger->info('Item "{key}" is locked, waiting for it to be released', ['key' => $item->getKey()]);
  123.                 flock($lock, \LOCK_SH);
  124.             } finally {
  125.                 flock($lock, \LOCK_UN);
  126.                 unset(self::$lockedFiles[$key]);
  127.             }
  128.             static $signalingException, $signalingCallback;
  129.             $signalingException = $signalingException ?? unserialize("O:9:\"Exception\":1:{s:16:\"\0Exception\0trace\";a:0:{}}");
  130.             $signalingCallback = $signalingCallback ?? function () use ($signalingException) { throw $signalingException; };
  132.             try {
  133.                 $value = $pool->get($item->getKey(), $signalingCallback, 0);
  134.                 $logger && $logger->info('Item "{key}" retrieved after lock was released', ['key' => $item->getKey()]);
  135.                 $save = false;
  137.                 return $value;
  138.             } catch (\Exception $e) {
  139.                 if ($signalingException !== $e) {
  140.                     throw $e;
  141.                 }
  142.                 $logger && $logger->info('Item "{key}" not found while lock was released, now retrying', ['key' => $item->getKey()]);
  143.             }
  144.         }
  146.         return null;
  147.     }
  149.     private static function open(int $key)
  150.     {
  151.         if (null !== $h = self::$openedFiles[$key] ?? null) {
  152.             return $h;
  153.         }
  154.         set_error_handler(function () {});
  155.         try {
  156.             $h = fopen(self::$files[$key], 'r+');
  157.         } finally {
  158.             restore_error_handler();
  159.         }
  161.         return self::$openedFiles[$key] = $h ?: @fopen(self::$files[$key], 'r');
  162.     }
  163. }
HTTP/2 401 returned for "https://api.hubapi.com/cms/v3/blogs/authors?hapikey=41d1972b-a2ce-454d-9e57-cd6355e00240". (500 Internal Server Error)

Symfony Exception

Symfony Docs

ClientException

HTTP 500 Internal Server Error

HTTP/2 401 returned for "https://api.hubapi.com/cms/v3/blogs/authors?hapikey=41d1972b-a2ce-454d-9e57-cd6355e00240".

Exception

Symfony\Component\HttpClient\Exception\ ClientException

in vendor/symfony/http-client/Response/TraceableResponse.php (line 212)
  1.         if (500 <= $code) {
  2.             throw new ServerException($this);
  3.         }
  5.         if (400 <= $code) {
  6.             throw new ClientException($this);
  7.         }
  9.         if (300 <= $code) {
  10.             throw new RedirectionException($this);
  11.         }
in vendor/symfony/http-client/Response/TraceableResponse.php -> checkStatusCode (line 103)
  1.         } finally {
  2.             if ($this->event && $this->event->isStarted()) {
  3.                 $this->event->stop();
  4.             }
  5.             if ($throw) {
  6.                 $this->checkStatusCode($this->response->getStatusCode());
  7.             }
  8.         }
  9.     }
  11.     public function toArray(bool $throw = true): array
TraceableResponse->getContent() in src/Blog.php (line 181)
  1.                     'hapikey' => $this->hubSpotKey,
  2.                     'after' => $after,
  3.                 ],
  4.             ]);
  6.             $result = json_decode($response->getContent(), true);
  7.         } catch (HttpExceptionInterface $e) {
  8.             $this->logger->error('Could not load blog posts from HubSpot', ['exception' => $e]);
  10.             throw $e;
  11.         }
Blog->loadBlogAuthors() in src/Blog.php (line 152)
  1.         if (!isset($this->authors)) {
  2.             $beta = $bustCache ? INF : null;
  3.             $this->authors = $this->cache->get('blog_authors', function (ItemInterface $item) {
  4.                 $item->expiresAfter(86400); // cache for 1 day
  6.                 return $this->loadBlogAuthors();
  7.             }, $beta);
  8.         }
  10.         return $this->authors;
  11.     }
in vendor/symfony/cache/Adapter/TraceableAdapter.php -> App\{closure} (line 51)
  2.         $isHit = true;
  3.         $callback = function (CacheItem $item, bool &$save) use ($callback, &$isHit) {
  4.             $isHit = $item->isHit();
  6.             return $callback($item, $save);
  7.         };
  9.         $event = $this->start(__FUNCTION__);
  10.         try {
  11.             $value = $this->pool->get($key, $callback, $beta, $metadata);
in vendor/symfony/cache/LockRegistry.php -> Symfony\Component\Cache\Adapter\{closure} (line 108)
  2.                 if ($locked || !$wouldBlock) {
  3.                     $logger && $logger->info(sprintf('Lock %s, now computing item "{key}"', $locked ? 'acquired' : 'not supported'), ['key' => $item->getKey()]);
  4.                     self::$lockedFiles[$key] = true;
  6.                     $value = $callback($item, $save);
  8.                     if ($save) {
  9.                         if ($setMetadata) {
  10.                             $setMetadata($item);
  11.                         }
in vendor/symfony/cache/Traits/ContractsTrait.php :: compute (line 100)
  1.             }
  3.             try {
  4.                 $value = ($this->callbackWrapper)($callback, $item, $save, $pool, function (CacheItem $item) use ($setMetadata, $startTime, &$metadata) {
  5.                     $setMetadata($item, $startTime, $metadata);
  6.                 }, $this->logger ?? null);
  7.                 $setMetadata($item, $startTime, $metadata);
  9.                 return $value;
  10.             } finally {
  11.                 unset($this->computing[$key]);
in vendor/symfony/cache-contracts/CacheTrait.php -> Symfony\Component\Cache\Traits\{closure} (line 72)
  1.             }
  2.         }
  4.         if ($recompute) {
  5.             $save = true;
  6.             $item->set($callback($item, $save));
  7.             if ($save) {
  8.                 $pool->save($item);
  9.             }
  10.         }
in vendor/symfony/cache/Traits/ContractsTrait.php -> contractsGet (line 107)
  2.                 return $value;
  3.             } finally {
  4.                 unset($this->computing[$key]);
  5.             }
  6.         }, $beta, $metadata, $this->logger ?? null);
  7.     }
  8. }
in vendor/symfony/cache-contracts/CacheTrait.php -> doGet (line 35)
  1.      *
  2.      * @return mixed
  3.      */
  4.     public function get(string $key, callable $callback, float $beta = null, array &$metadata = null)
  5.     {
  6.         return $this->doGet($this, $key, $callback, $beta, $metadata);
  7.     }
  9.     /**
  10.      * {@inheritdoc}
  11.      */
in vendor/symfony/cache/Adapter/TraceableAdapter.php -> get (line 56)
  1.             return $callback($item, $save);
  2.         };
  4.         $event = $this->start(__FUNCTION__);
  5.         try {
  6.             $value = $this->pool->get($key, $callback, $beta, $metadata);
  7.             $event->result[$key] = get_debug_type($value);
  8.         } finally {
  9.             $event->end = microtime(true);
  10.         }
  11.         if ($isHit) {
TraceableAdapter->get('blog_authors', object(Closure), INF) in src/Blog.php (line 149)
  2.     public function getAuthors(bool $bustCache = false): array
  3.     {
  4.         if (!isset($this->authors)) {
  5.             $beta = $bustCache ? INF : null;
  6.             $this->authors = $this->cache->get('blog_authors', function (ItemInterface $item) {
  7.                 $item->expiresAfter(86400); // cache for 1 day
  9.                 return $this->loadBlogAuthors();
  10.             }, $beta);
  11.         }
Blog->getAuthors(true) in src/Blog.php (line 37)
  1.      * WARNING: This will be slow and should not be called
  2.      * unless intentional.
  3.      */
  4.     public function bustCache(): void
  5.     {
  6.         $this->getAuthors(true);
  7.         $this->getTags(true);
  8.         $this->getAllPosts(true);
  9.     }
  11.     public function getAuthor(string $slug): ?array
Blog->bustCache() in src/EventSubscriber/ContentRefreshSubscriber.php (line 45)
  1.         // Update the last refresh time now to minimize cache stampede
  2.         $this->cache->get('lastContentRefresh', function () {
  3.             return time();
  4.         }, INF);
  6.         $this->blog->bustCache();
  7.     }
  9.     public static function getSubscribedEvents(): array
  10.     {
  11.         return [
ContentRefreshSubscriber->refresh() in src/EventSubscriber/ContentRefreshSubscriber.php (line 34)
  1.         $lastRefresh = $this->cache->get('lastContentRefresh', function () {
  2.             return 0;
  3.         });
  5.         if ($lastRefresh < strtotime('-5 minutes')) {
  6.             $this->refresh();
  7.         }
  8.     }
  10.     private function refresh(): void
  11.     {
in vendor/symfony/event-dispatcher/EventDispatcher.php -> onKernelTerminate (line 270)
  1.                     $closure = static function (...$args) use (&$listener, &$closure) {
  2.                         if ($listener[0] instanceof \Closure) {
  3.                             $listener[0] = $listener[0]();
  4.                             $listener[1] = $listener[1] ?? '__invoke';
  5.                         }
  6.                         ($closure = \Closure::fromCallable($listener))(...$args);
  7.                     };
  8.                 } else {
  9.                     $closure = $listener instanceof \Closure || $listener instanceof WrappedListener ? $listener : \Closure::fromCallable($listener);
  10.                 }
  11.             }
in vendor/symfony/event-dispatcher/EventDispatcher.php :: Symfony\Component\EventDispatcher\{closure} (line 230)
  2.         foreach ($listeners as $listener) {
  3.             if ($stoppable && $event->isPropagationStopped()) {
  4.                 break;
  5.             }
  6.             $listener($event, $eventName, $this);
  7.         }
  8.     }
  10.     /**
  11.      * Sorts the internal list of listeners for the given event by priority.
in vendor/symfony/event-dispatcher/EventDispatcher.php -> callListeners (line 59)
  1.         } else {
  2.             $listeners = $this->getListeners($eventName);
  3.         }
  5.         if ($listeners) {
  6.             $this->callListeners($listeners, $eventName, $event);
  7.         }
  9.         return $event;
  10.     }
in vendor/symfony/http-kernel/HttpKernel.php -> dispatch (line 94)
  1.     /**
  2.      * {@inheritdoc}
  3.      */
  4.     public function terminate(Request $request, Response $response)
  5.     {
  6.         $this->dispatcher->dispatch(new TerminateEvent($this, $request, $response), KernelEvents::TERMINATE);
  7.     }
  9.     /**
  10.      * @internal
  11.      */
in vendor/symfony/http-kernel/Kernel.php -> terminate (line 159)
  1.         if (false === $this->booted) {
  2.             return;
  3.         }
  5.         if ($this->getHttpKernel() instanceof TerminableInterface) {
  6.             $this->getHttpKernel()->terminate($request, $response);
  7.         }
  8.     }
  10.     /**
  11.      * {@inheritdoc}
Kernel->terminate(object(Request), object(Response)) in public/index.php (line 36)
  2. $kernel = new Kernel($_SERVER['APP_ENV'], (bool) $_SERVER['APP_DEBUG']);
  3. $request = Request::createFromGlobals();
  4. $response = $kernel->handle($request);
  5. $response->send();
  6. $kernel->terminate($request, $response);

Logs 3

Level Channel Message
INFO 16:52:24 php User Deprecated: Since symfony/framework-bundle 5.3: The "session.storage.native" service is deprecated, use "session.storage.factory.native" instead. 
{
    "exception": {}
}
INFO 16:52:24 php User Deprecated: Since symfony/framework-bundle 5.3: The "session.storage.metadata_bag" service is deprecated, create your own "session.storage.factory" instead. 
{
    "exception": {}
}
INFO 16:52:24 request Matched route "_profiler_open_file". 
{
    "route": "_profiler_open_file",
    "route_parameters": {
        "_route": "_profiler_open_file",
        "_controller": "web_profiler.controller.profiler::openAction"
    },
    "request_uri": "http://invoiced.project-release.info/_profiler/open?file=vendor%2Fsymfony%2Fcache%2FLockRegistry.php&line=85",
    "method": "GET"
}
INFO 16:52:24 cache Lock acquired, now computing item "lastContentRefresh" 
{
    "key": "lastContentRefresh"
}
INFO 16:52:24 cache Lock acquired, now computing item "blog_authors" 
{
    "key": "blog_authors"
}
INFO 16:52:24 http_client Request: "GET https://api.hubapi.com/cms/v3/blogs/authors?hapikey=41d1972b-a2ce-454d-9e57-cd6355e00240"
INFO 16:52:24 http_client Response: "401 https://api.hubapi.com/cms/v3/blogs/authors?hapikey=41d1972b-a2ce-454d-9e57-cd6355e00240"
ERROR 16:52:24 app Could not load blog posts from HubSpot 
{
    "exception": {}
}
CRITICAL 16:52:24 php Uncaught Exception: HTTP/2 401 returned for "https://api.hubapi.com/cms/v3/blogs/authors?hapikey=41d1972b-a2ce-454d-9e57-cd6355e00240". 
{
    "exception": {}
}
CRITICAL 16:52:24 request Uncaught PHP Exception Symfony\Component\HttpClient\Exception\ClientException: "HTTP/2 401 returned for "https://api.hubapi.com/cms/v3/blogs/authors?hapikey=41d1972b-a2ce-454d-9e57-cd6355e00240"." at /var/www/invoiced/data/www/invoiced.project-release.info/vendor/symfony/http-client/Response/TraceableResponse.php line 212 
{
    "exception": {}
}

Stack Trace

ClientException 
Symfony\Component\HttpClient\Exception\ClientException:
HTTP/2 401  returned for "https://api.hubapi.com/cms/v3/blogs/authors?hapikey=41d1972b-a2ce-454d-9e57-cd6355e00240".

  at vendor/symfony/http-client/Response/TraceableResponse.php:212
  at Symfony\Component\HttpClient\Response\TraceableResponse->checkStatusCode(401)
     (vendor/symfony/http-client/Response/TraceableResponse.php:103)
  at Symfony\Component\HttpClient\Response\TraceableResponse->getContent()
     (src/Blog.php:181)
  at App\Blog->loadBlogAuthors()
     (src/Blog.php:152)
  at App\Blog->App\{closure}(object(CacheItem), true)
     (vendor/symfony/cache/Adapter/TraceableAdapter.php:51)
  at Symfony\Component\Cache\Adapter\TraceableAdapter->Symfony\Component\Cache\Adapter\{closure}(object(CacheItem), true)
     (vendor/symfony/cache/LockRegistry.php:108)
  at Symfony\Component\Cache\LockRegistry::compute(object(Closure), object(CacheItem), true, object(FilesystemAdapter), object(Closure), object(Logger))
     (vendor/symfony/cache/Traits/ContractsTrait.php:100)
  at Symfony\Component\Cache\Adapter\AbstractAdapter->Symfony\Component\Cache\Traits\{closure}(object(CacheItem), true)
     (vendor/symfony/cache-contracts/CacheTrait.php:72)
  at Symfony\Component\Cache\Adapter\AbstractAdapter->contractsGet(object(FilesystemAdapter), 'blog_authors', object(Closure), INF, array(), object(Logger))
     (vendor/symfony/cache/Traits/ContractsTrait.php:107)
  at Symfony\Component\Cache\Adapter\AbstractAdapter->doGet(object(FilesystemAdapter), 'blog_authors', object(Closure), INF, array())
     (vendor/symfony/cache-contracts/CacheTrait.php:35)
  at Symfony\Component\Cache\Adapter\AbstractAdapter->get('blog_authors', object(Closure), INF, array())
     (vendor/symfony/cache/Adapter/TraceableAdapter.php:56)
  at Symfony\Component\Cache\Adapter\TraceableAdapter->get('blog_authors', object(Closure), INF)
     (src/Blog.php:149)
  at App\Blog->getAuthors(true)
     (src/Blog.php:37)
  at App\Blog->bustCache()
     (src/EventSubscriber/ContentRefreshSubscriber.php:45)
  at App\EventSubscriber\ContentRefreshSubscriber->refresh()
     (src/EventSubscriber/ContentRefreshSubscriber.php:34)
  at App\EventSubscriber\ContentRefreshSubscriber->onKernelTerminate(object(TerminateEvent), 'kernel.terminate', object(EventDispatcher))
     (vendor/symfony/event-dispatcher/EventDispatcher.php:270)
  at Symfony\Component\EventDispatcher\EventDispatcher::Symfony\Component\EventDispatcher\{closure}(object(TerminateEvent), 'kernel.terminate', object(EventDispatcher))
     (vendor/symfony/event-dispatcher/EventDispatcher.php:230)
  at Symfony\Component\EventDispatcher\EventDispatcher->callListeners(array(object(Closure), object(Closure)), 'kernel.terminate', object(TerminateEvent))
     (vendor/symfony/event-dispatcher/EventDispatcher.php:59)
  at Symfony\Component\EventDispatcher\EventDispatcher->dispatch(object(TerminateEvent), 'kernel.terminate')
     (vendor/symfony/http-kernel/HttpKernel.php:94)
  at Symfony\Component\HttpKernel\HttpKernel->terminate(object(Request), object(Response))
     (vendor/symfony/http-kernel/Kernel.php:159)
  at Symfony\Component\HttpKernel\Kernel->terminate(object(Request), object(Response))
     (public/index.php:36)