| 123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139 | <?php/* * This file is part of the Symfony package. * * (c) Fabien Potencier <fabien@symfony.com> * * For the full copyright and license information, please view the LICENSE * file that was distributed with this source code. */namespace Symfony\Component\HttpFoundation\Session\Storage\Handler;/** * MemcacheSessionHandler. * * @author Drak <drak@zikula.org> */class MemcacheSessionHandler implements \SessionHandlerInterface{    /**     * Memcache driver.     *     * @var \Memcache     */    private $memcache;    /**     * Configuration options.     *     * @var array     */    private $memcacheOptions;    /**     * Key prefix for shared environments.     *     * @var string     */    private $prefix;    /**     * Constructor.     *     * @param \Memcache $memcache        A \Memcache instance     * @param array     $memcacheOptions An associative array of Memcache options     * @param array     $options         Session configuration options.     */    public function __construct(\Memcache $memcache, array $memcacheOptions = array(), array $options = array())    {        $this->memcache = $memcache;        // defaults        if (!isset($memcacheOptions['serverpool'])) {            $memcacheOptions['serverpool'] = array(array(                'host' => '127.0.0.1',                'port' => 11211,                'timeout' => 1,                'persistent' => false,                'weight' => 1,                'retry_interval' => 15,            ));        }        $memcacheOptions['expiretime'] = isset($memcacheOptions['expiretime']) ? (int)$memcacheOptions['expiretime'] : 86400;        $this->prefix = isset($memcacheOptions['prefix']) ? $memcacheOptions['prefix'] : 'sf2s';        $this->memcacheOptions = $memcacheOptions;    }    protected function addServer(array $server)    {        if (!array_key_exists('host', $server)) {            throw new \InvalidArgumentException('host key must be set');        }        $server['port'] = isset($server['port']) ? (int)$server['port'] : 11211;        $server['timeout'] = isset($server['timeout']) ? (int)$server['timeout'] : 1;        $server['persistent'] = isset($server['persistent']) ? (bool)$server['persistent'] : false;        $server['weight'] = isset($server['weight']) ? (int)$server['weight'] : 1;        $server['retry_interval'] = isset($server['retry_interval']) ? (int)$server['retry_interval'] : 15;        $this->memcache->addserver($server['host'], $server['port'], $server['persistent'],$server['weight'],$server['timeout'],$server['retry_interval']);    }    /**     * {@inheritdoc}     */    public function open($savePath, $sessionName)    {        foreach ($this->memcacheOptions['serverpool'] as $server) {            $this->addServer($server);        }        return true;    }    /**     * {@inheritdoc}     */    public function close()    {        return $this->memcache->close();    }    /**     * {@inheritdoc}     */    public function read($sessionId)    {        return $this->memcache->get($this->prefix.$sessionId) ?: '';    }    /**     * {@inheritdoc}     */    public function write($sessionId, $data)    {        return $this->memcache->set($this->prefix.$sessionId, $data, 0, $this->memcacheOptions['expiretime']);    }    /**     * {@inheritdoc}     */    public function destroy($sessionId)    {        return $this->memcache->delete($this->prefix.$sessionId);    }    /**     * {@inheritdoc}     */    public function gc($lifetime)    {        // not required here because memcache will auto expire the records anyhow.        return true;    }}
 |