123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208 |
- <?php
- namespace Symfony\Component\Cache\Adapter;
- use Psr\Log\LoggerAwareInterface;
- use Psr\Log\LoggerInterface;
- use Symfony\Component\Cache\CacheItem;
- use Symfony\Component\Cache\Exception\InvalidArgumentException;
- use Symfony\Component\Cache\ResettableInterface;
- use Symfony\Component\Cache\Traits\AbstractAdapterTrait;
- use Symfony\Component\Cache\Traits\ContractsTrait;
- use Symfony\Contracts\Cache\CacheInterface;
- abstract class AbstractAdapter implements AdapterInterface, CacheInterface, LoggerAwareInterface, ResettableInterface
- {
- use AbstractAdapterTrait;
- use ContractsTrait;
-
- protected const NS_SEPARATOR = ':';
- private static $apcuSupported;
- private static $phpFilesSupported;
- protected function __construct(string $namespace = '', int $defaultLifetime = 0)
- {
- $this->namespace = '' === $namespace ? '' : CacheItem::validateKey($namespace).static::NS_SEPARATOR;
- $this->defaultLifetime = $defaultLifetime;
- if (null !== $this->maxIdLength && \strlen($namespace) > $this->maxIdLength - 24) {
- throw new InvalidArgumentException(sprintf('Namespace must be %d chars max, %d given ("%s").', $this->maxIdLength - 24, \strlen($namespace), $namespace));
- }
- self::$createCacheItem ?? self::$createCacheItem = \Closure::bind(
- static function ($key, $value, $isHit) {
- $item = new CacheItem();
- $item->key = $key;
- $item->value = $v = $value;
- $item->isHit = $isHit;
-
-
-
- if (\is_array($v) && 1 === \count($v) && 10 === \strlen($k = (string) array_key_first($v)) && "\x9D" === $k[0] && "\0" === $k[5] && "\x5F" === $k[9]) {
- $item->value = $v[$k];
- $v = unpack('Ve/Nc', substr($k, 1, -1));
- $item->metadata[CacheItem::METADATA_EXPIRY] = $v['e'] + CacheItem::METADATA_EXPIRY_OFFSET;
- $item->metadata[CacheItem::METADATA_CTIME] = $v['c'];
- }
- return $item;
- },
- null,
- CacheItem::class
- );
- self::$mergeByLifetime ?? self::$mergeByLifetime = \Closure::bind(
- static function ($deferred, $namespace, &$expiredIds, $getId, $defaultLifetime) {
- $byLifetime = [];
- $now = microtime(true);
- $expiredIds = [];
- foreach ($deferred as $key => $item) {
- $key = (string) $key;
- if (null === $item->expiry) {
- $ttl = 0 < $defaultLifetime ? $defaultLifetime : 0;
- } elseif (!$item->expiry) {
- $ttl = 0;
- } elseif (0 >= $ttl = (int) (0.1 + $item->expiry - $now)) {
- $expiredIds[] = $getId($key);
- continue;
- }
- if (isset(($metadata = $item->newMetadata)[CacheItem::METADATA_TAGS])) {
- unset($metadata[CacheItem::METADATA_TAGS]);
- }
-
- $byLifetime[$ttl][$getId($key)] = $metadata ? ["\x9D".pack('VN', (int) (0.1 + $metadata[self::METADATA_EXPIRY] - self::METADATA_EXPIRY_OFFSET), $metadata[self::METADATA_CTIME])."\x5F" => $item->value] : $item->value;
- }
- return $byLifetime;
- },
- null,
- CacheItem::class
- );
- }
-
- public static function createSystemCache(string $namespace, int $defaultLifetime, string $version, string $directory, LoggerInterface $logger = null)
- {
- $opcache = new PhpFilesAdapter($namespace, $defaultLifetime, $directory, true);
- if (null !== $logger) {
- $opcache->setLogger($logger);
- }
- if (!self::$apcuSupported = self::$apcuSupported ?? ApcuAdapter::isSupported()) {
- return $opcache;
- }
- if (\in_array(\PHP_SAPI, ['cli', 'phpdbg'], true) && !filter_var(\ini_get('apc.enable_cli'), \FILTER_VALIDATE_BOOLEAN)) {
- return $opcache;
- }
- $apcu = new ApcuAdapter($namespace, intdiv($defaultLifetime, 5), $version);
- if (null !== $logger) {
- $apcu->setLogger($logger);
- }
- return new ChainAdapter([$apcu, $opcache]);
- }
- public static function createConnection(string $dsn, array $options = [])
- {
- if (str_starts_with($dsn, 'redis:') || str_starts_with($dsn, 'rediss:')) {
- return RedisAdapter::createConnection($dsn, $options);
- }
- if (str_starts_with($dsn, 'memcached:')) {
- return MemcachedAdapter::createConnection($dsn, $options);
- }
- if (0 === strpos($dsn, 'couchbase:')) {
- if (CouchbaseBucketAdapter::isSupported()) {
- return CouchbaseBucketAdapter::createConnection($dsn, $options);
- }
- return CouchbaseCollectionAdapter::createConnection($dsn, $options);
- }
- throw new InvalidArgumentException(sprintf('Unsupported DSN: "%s".', $dsn));
- }
-
- public function commit()
- {
- $ok = true;
- $byLifetime = (self::$mergeByLifetime)($this->deferred, $this->namespace, $expiredIds, \Closure::fromCallable([$this, 'getId']), $this->defaultLifetime);
- $retry = $this->deferred = [];
- if ($expiredIds) {
- try {
- $this->doDelete($expiredIds);
- } catch (\Exception $e) {
- $ok = false;
- CacheItem::log($this->logger, 'Failed to delete expired items: '.$e->getMessage(), ['exception' => $e, 'cache-adapter' => get_debug_type($this)]);
- }
- }
- foreach ($byLifetime as $lifetime => $values) {
- try {
- $e = $this->doSave($values, $lifetime);
- } catch (\Exception $e) {
- }
- if (true === $e || [] === $e) {
- continue;
- }
- if (\is_array($e) || 1 === \count($values)) {
- foreach (\is_array($e) ? $e : array_keys($values) as $id) {
- $ok = false;
- $v = $values[$id];
- $type = get_debug_type($v);
- $message = sprintf('Failed to save key "{key}" of type %s%s', $type, $e instanceof \Exception ? ': '.$e->getMessage() : '.');
- CacheItem::log($this->logger, $message, ['key' => substr($id, \strlen($this->namespace)), 'exception' => $e instanceof \Exception ? $e : null, 'cache-adapter' => get_debug_type($this)]);
- }
- } else {
- foreach ($values as $id => $v) {
- $retry[$lifetime][] = $id;
- }
- }
- }
-
- foreach ($retry as $lifetime => $ids) {
- foreach ($ids as $id) {
- try {
- $v = $byLifetime[$lifetime][$id];
- $e = $this->doSave([$id => $v], $lifetime);
- } catch (\Exception $e) {
- }
- if (true === $e || [] === $e) {
- continue;
- }
- $ok = false;
- $type = get_debug_type($v);
- $message = sprintf('Failed to save key "{key}" of type %s%s', $type, $e instanceof \Exception ? ': '.$e->getMessage() : '.');
- CacheItem::log($this->logger, $message, ['key' => substr($id, \strlen($this->namespace)), 'exception' => $e instanceof \Exception ? $e : null, 'cache-adapter' => get_debug_type($this)]);
- }
- }
- return $ok;
- }
- }
|