123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171 |
- <?php
- namespace OC\Memcache;
- use OCP\HintException;
- use OCP\IMemcache;
- class Memcached extends Cache implements IMemcache {
- use CASTrait;
-
- private static $cache = null;
- use CADTrait;
- public function __construct($prefix = '') {
- parent::__construct($prefix);
- if (is_null(self::$cache)) {
- self::$cache = new \Memcached();
- $defaultOptions = [
- \Memcached::OPT_CONNECT_TIMEOUT => 50,
- \Memcached::OPT_RETRY_TIMEOUT => 50,
- \Memcached::OPT_SEND_TIMEOUT => 50,
- \Memcached::OPT_RECV_TIMEOUT => 50,
- \Memcached::OPT_POLL_TIMEOUT => 50,
-
- \Memcached::OPT_COMPRESSION => true,
-
- \Memcached::OPT_LIBKETAMA_COMPATIBLE => true,
-
- \Memcached::OPT_BINARY_PROTOCOL => true,
- ];
-
- if (\Memcached::HAVE_IGBINARY) {
- $defaultOptions[\Memcached::OPT_SERIALIZER] =
- \Memcached::SERIALIZER_IGBINARY;
- }
- $options = \OC::$server->getConfig()->getSystemValue('memcached_options', []);
- if (is_array($options)) {
- $options = $options + $defaultOptions;
- self::$cache->setOptions($options);
- } else {
- throw new HintException("Expected 'memcached_options' config to be an array, got $options");
- }
- $servers = \OC::$server->getSystemConfig()->getValue('memcached_servers');
- if (!$servers) {
- $server = \OC::$server->getSystemConfig()->getValue('memcached_server');
- if ($server) {
- $servers = [$server];
- } else {
- $servers = [['localhost', 11211]];
- }
- }
- self::$cache->addServers($servers);
- }
- }
-
- protected function getNameSpace() {
- return $this->prefix;
- }
- public function get($key) {
- $result = self::$cache->get($this->getNameSpace() . $key);
- if ($result === false and self::$cache->getResultCode() == \Memcached::RES_NOTFOUND) {
- return null;
- } else {
- return $result;
- }
- }
- public function set($key, $value, $ttl = 0) {
- if ($ttl > 0) {
- $result = self::$cache->set($this->getNameSpace() . $key, $value, $ttl);
- } else {
- $result = self::$cache->set($this->getNameSpace() . $key, $value);
- }
- return $result || $this->isSuccess();
- }
- public function hasKey($key) {
- self::$cache->get($this->getNameSpace() . $key);
- return self::$cache->getResultCode() === \Memcached::RES_SUCCESS;
- }
- public function remove($key) {
- $result = self::$cache->delete($this->getNameSpace() . $key);
- return $result || $this->isSuccess() || self::$cache->getResultCode() === \Memcached::RES_NOTFOUND;
- }
- public function clear($prefix = '') {
-
- self::$cache->flush();
- return true;
- }
-
- public function add($key, $value, $ttl = 0) {
- $result = self::$cache->add($this->getPrefix() . $key, $value, $ttl);
- return $result || $this->isSuccess();
- }
-
- public function inc($key, $step = 1) {
- $this->add($key, 0);
- $result = self::$cache->increment($this->getPrefix() . $key, $step);
- if (self::$cache->getResultCode() !== \Memcached::RES_SUCCESS) {
- return false;
- }
- return $result;
- }
-
- public function dec($key, $step = 1) {
- $result = self::$cache->decrement($this->getPrefix() . $key, $step);
- if (self::$cache->getResultCode() !== \Memcached::RES_SUCCESS) {
- return false;
- }
- return $result;
- }
- public static function isAvailable(): bool {
- return extension_loaded('memcached');
- }
- private function isSuccess(): bool {
- return self::$cache->getResultCode() === \Memcached::RES_SUCCESS;
- }
- }
|