X-Git-Url: https://git.mxchange.org/?a=blobdiff_plain;ds=sidebyside;f=src%2FCore%2FCache%2FMemcachedCacheDriver.php;h=d4aab15c92430045bb5d058ca2a6889afdcf28af;hb=1e96faca4c9825bf6a8d8a50dc37498b764b9a3d;hp=8f1752cbed0ce5169b4b976abbb674e552f9fc73;hpb=cc688e2b4f52afda5c54a14492c57273f97b23a2;p=friendica.git diff --git a/src/Core/Cache/MemcachedCacheDriver.php b/src/Core/Cache/MemcachedCacheDriver.php index 8f1752cbed..d4aab15c92 100644 --- a/src/Core/Cache/MemcachedCacheDriver.php +++ b/src/Core/Cache/MemcachedCacheDriver.php @@ -1,68 +1,100 @@ - - */ -class MemcachedCacheDriver extends BaseObject implements ICacheDriver -{ - /** - * @var Memcached - */ - private $memcached; - - public function __construct(array $memcached_hosts) - { - if (!class_exists('Memcached', false)) { - throw new \Exception('Memcached class isn\'t available'); - } - - $this->memcached = new \Memcached(); - - $this->memcached->addServers($memcached_hosts); - - if (count($this->memcached->getServerList()) == 0) { - throw new \Exception('Expected Memcached servers aren\'t available, config:' . var_export($memcached_hosts, true)); - } - } - - public function get($key) - { - $return = null; - - // We fetch with the hostname as key to avoid problems with other applications - $value = $this->memcached->get(self::getApp()->get_hostname() . ':' . $key); - - if ($this->memcached->getResultCode() === \Memcached::RES_SUCCESS) { - $return = $value; - } - - return $return; - } - - public function set($key, $value, $duration = Cache::MONTH) - { - // We store with the hostname as key to avoid problems with other applications - return $this->memcached->set( - self::getApp()->get_hostname() . ":" . $key, - $value, - Cache::duration($duration) - ); - } - - public function delete($key) - { - return $this->memcached->delete($key); - } - - public function clear() - { - return true; - } -} + + */ +class MemcachedCacheDriver extends AbstractCacheDriver implements IMemoryCacheDriver +{ + use TraitCompareSet; + use TraitCompareDelete; + + /** + * @var \Memcached + */ + private $memcached; + + public function __construct(array $memcached_hosts) + { + if (!class_exists('Memcached', false)) { + throw new \Exception('Memcached class isn\'t available'); + } + + $this->memcached = new \Memcached(); + + $this->memcached->addServers($memcached_hosts); + + if (count($this->memcached->getServerList()) == 0) { + throw new \Exception('Expected Memcached servers aren\'t available, config:' . var_export($memcached_hosts, true)); + } + } + + public function get($key) + { + $return = null; + $cachekey = $this->getCacheKey($key); + + // We fetch with the hostname as key to avoid problems with other applications + $value = $this->memcached->get($cachekey); + + if ($this->memcached->getResultCode() === \Memcached::RES_SUCCESS) { + $return = $value; + } + + return $return; + } + + public function set($key, $value, $ttl = Cache::FIVE_MINUTES) + { + $cachekey = $this->getCacheKey($key); + + // We store with the hostname as key to avoid problems with other applications + if ($ttl > 0) { + return $this->memcached->set( + $cachekey, + $value, + $ttl + ); + } else { + return $this->memcached->set( + $cachekey, + $value + ); + } + + } + + public function delete($key) + { + $cachekey = $this->getCacheKey($key); + return $this->memcached->delete($cachekey); + } + + public function clear($outdated = true) + { + if ($outdated) { + return true; + } else { + return $this->memcached->flush(); + } + } + + /** + * @brief Sets a value if it's not already stored + * + * @param string $key The cache key + * @param mixed $value The old value we know from the cache + * @param int $ttl The cache lifespan, must be one of the Cache constants + * @return bool + */ + public function add($key, $value, $ttl = Cache::FIVE_MINUTES) + { + $cachekey = $this->getCacheKey($key); + return $this->memcached->add($cachekey, $value, $ttl); + } +}