136 lines
3.6 KiB
PHP
136 lines
3.6 KiB
PHP
<?php
|
|
/**
|
|
* Page Cache Ultimate, Page Cache standard and Speed pack are powered by Jpresta (jpresta . com)
|
|
*
|
|
* @author Jpresta
|
|
* @copyright Jpresta
|
|
* @license See the license of this module in file LICENSE.txt, thank you.
|
|
*/
|
|
|
|
if (!defined('_PS_VERSION_')) {exit;}
|
|
|
|
if (!class_exists('PageCacheCacheMemcached')) {
|
|
|
|
class PageCacheCacheMemcached extends PageCacheCache
|
|
{
|
|
/**
|
|
* @var Memcached
|
|
*/
|
|
private $memcached;
|
|
|
|
/**
|
|
* @var bool Connection status
|
|
*/
|
|
private $is_configured = false;
|
|
|
|
public function __construct($host, $port)
|
|
{
|
|
$this->connect($host, $port);
|
|
}
|
|
|
|
/**
|
|
* Connect to memcache server.
|
|
*/
|
|
public function connect($host, $port)
|
|
{
|
|
if (class_exists('Memcached') && extension_loaded('memcached')) {
|
|
$this->memcached = new Memcached();
|
|
$this->is_configured = @$this->memcached->addServer($host, $port);
|
|
}
|
|
}
|
|
|
|
/**
|
|
* @return bool
|
|
*/
|
|
public function isConnected($host, $port)
|
|
{
|
|
$statuses = $this->memcached->getStats();
|
|
return isset($statuses[$host . ':' . ($port !== 0 ? $port : '11211')]);
|
|
}
|
|
|
|
public function getResultMessage()
|
|
{
|
|
if ($this->memcached) {
|
|
return $this->memcached->getResultMessage() . ' (' . $this->memcached->getResultCode() . ')';
|
|
}
|
|
return '';
|
|
}
|
|
|
|
public function getVersion()
|
|
{
|
|
if (!$this->is_configured) {
|
|
return '';
|
|
}
|
|
$version = $this->memcached->getVersion();
|
|
if (is_array($version)) {
|
|
$rev = array_reverse($version);
|
|
$version = array_pop($rev);
|
|
}
|
|
return $version;
|
|
}
|
|
|
|
public static function isCompatible()
|
|
{
|
|
// Check extension
|
|
return class_exists('CacheMemcached')
|
|
&& class_exists('Memcached')
|
|
&& extension_loaded('memcached');
|
|
}
|
|
|
|
/**
|
|
* @param $url string
|
|
* @param $contextKey string
|
|
* @return string
|
|
*/
|
|
private static function getCacheKey($url, $contextKey)
|
|
{
|
|
return md5($url . $contextKey);
|
|
}
|
|
|
|
public function get($url, $contextKey, $ttl = -1)
|
|
{
|
|
if (!$this->is_configured) {
|
|
return false;
|
|
}
|
|
if ($ttl < -1) {
|
|
;
|
|
} // Avoid Prestashop validator "Unused function parameter $ttl."
|
|
return $this->memcached->get(self::getCacheKey($url, $contextKey));
|
|
}
|
|
|
|
public function set($url, $contextKey, $value, $ttl = -1)
|
|
{
|
|
if ($this->is_configured) {
|
|
if ($ttl < 0) {
|
|
$ttl = 0;
|
|
}
|
|
$result = $this->memcached->set(self::getCacheKey($url, $contextKey), $value, $ttl);
|
|
|
|
if ($result === false) {
|
|
// TODO Log something
|
|
}
|
|
}
|
|
}
|
|
|
|
public function delete($url, $contextKey)
|
|
{
|
|
if ($this->is_configured) {
|
|
return (bool)$this->memcached->delete(self::getCacheKey($url, $contextKey));
|
|
}
|
|
return true;
|
|
}
|
|
|
|
public function flush($timeoutSeconds = 0)
|
|
{
|
|
if ($this->is_configured) {
|
|
return (bool)$this->memcached->flush();
|
|
}
|
|
return true;
|
|
}
|
|
|
|
public function purge($timeoutSeconds = 0)
|
|
{
|
|
}
|
|
}
|
|
}
|