ElggMemcache.php

Go to the documentation of this file.

<?php
class ElggMemcache extends \ElggSharedMemoryCache {
    private $CONFIG;
 
    private static $MINSERVERVERSION = '1.1.12';
 
    private $memcache;
 
    private $expires = 86400;
 
    private $version = 0;
 
    public function __construct($namespace = 'default') {
        global $CONFIG;
        $this->CONFIG = $CONFIG;
 
        $this->setNamespace($namespace);
 
        // Do we have memcache?
        if (!class_exists('Memcache')) {
            throw new \ConfigurationException('PHP memcache module not installed, you must install php5-memcache');
        }
 
        // Create memcache object
        $this->memcache = new Memcache;
 
        // Now add servers
        if (!$this->CONFIG->memcache_servers) {
            throw new \ConfigurationException('No memcache servers defined, please populate the $this->CONFIG->memcache_servers variable');
        }
 
        if (is_callable(array($this->memcache, 'addServer'))) {
            foreach ($this->CONFIG->memcache_servers as $server) {
                if (is_array($server)) {
                    $this->memcache->addServer(
                        $server[0],
                        isset($server[1]) ? $server[1] : 11211,
                        isset($server[2]) ? $server[2] : false,
                        isset($server[3]) ? $server[3] : 1,
                        isset($server[4]) ? $server[4] : 1,
                        isset($server[5]) ? $server[5] : 15,
                        isset($server[6]) ? $server[6] : true
                    );
 
                } else {
                    $this->memcache->addServer($server, 11211);
                }
            }
        } else {
            // don't use _elgg_services()->translator->translate() here because most of the config hasn't been loaded yet
            // and it caches the language, which is hard coded in $this->CONFIG->language as en.
            // overriding it with real values later has no effect because it's already cached.
            _elgg_services()->logger->error("This version of the PHP memcache API doesn't support multiple servers.");
 
            $server = $this->CONFIG->memcache_servers[0];
            if (is_array($server)) {
                $this->memcache->connect($server[0], $server[1]);
            } else {
                $this->memcache->addServer($server, 11211);
            }
        }
 
        // Get version
        $this->version = $this->memcache->getVersion();
        if (version_compare($this->version, \ElggMemcache::$MINSERVERVERSION, '<')) {
            $msg = vsprintf('Memcache needs at least version %s to run, you are running %s',
                array(\ElggMemcache::$MINSERVERVERSION,
                $this->version
            ));
 
            throw new \ConfigurationException($msg);
        }
 
        // Set some defaults
        if (isset($this->CONFIG->memcache_expires)) {
            $this->expires = $this->CONFIG->memcache_expires;
        }
        
        // make sure memcache is reset
        _elgg_services()->events->registerHandler('cache:flush', 'system', array($this, 'clear'));
    }
 
    public function setDefaultExpiry($expires = 0) {
        $this->expires = $expires;
    }
 
    private function makeMemcacheKey($key) {
        $prefix = $this->getNamespace() . ":";
 
        if (strlen($prefix . $key) > 250) {
            $key = md5($key);
        }
 
        return $prefix . $key;
    }
 
    public function save($key, $data, $expires = null) {
        $key = $this->makeMemcacheKey($key);
 
        if ($expires === null) {
            $expires = $this->expires;
        }
 
        $result = $this->memcache->set($key, $data, null, $expires);
        if ($result === false) {
            _elgg_services()->logger->error("MEMCACHE: SAVE FAIL $key");
        } else {
            _elgg_services()->logger->info("MEMCACHE: SAVE SUCCESS $key");
        }
 
        return $result;
    }
 
    public function load($key, $offset = 0, $limit = null) {
        $key = $this->makeMemcacheKey($key);
 
        $result = $this->memcache->get($key);
        if ($result === false) {
            _elgg_services()->logger->info("MEMCACHE: LOAD MISS $key");
        } else {
            _elgg_services()->logger->info("MEMCACHE: LOAD HIT $key");
        }
 
        return $result;
    }
 
    public function delete($key) {
        $key = $this->makeMemcacheKey($key);
 
        return $this->memcache->delete($key, 0);
    }
 
    public function clear() {
        $result = $this->memcache->flush();
        if ($result === false) {
            _elgg_services()->logger->info("MEMCACHE: failed to flush {$this->getNamespace()}");
        } else {
            sleep(1); // needed because http://php.net/manual/en/memcache.flush.php#81420
            
            _elgg_services()->logger->info("MEMCACHE: flushed {$this->getNamespace()}");
        }
        
        return $result;
 
        // @todo Namespaces as in #532
    }
}