| Server IP : 37.220.80.31 / Your IP : 3.133.158.116 Web Server : Apache/2.4.52 (Ubuntu) System : Linux 3051455-guretool.twc1.net 5.15.0-107-generic #117-Ubuntu SMP Fri Apr 26 12:26:49 UTC 2024 x86_64 User : www-root ( 1010) PHP Version : 7.4.33 Disable Function : pcntl_alarm,pcntl_fork,pcntl_waitpid,pcntl_wait,pcntl_wifexited,pcntl_wifstopped,pcntl_wifsignaled,pcntl_wexitstatus,pcntl_wtermsig,pcntl_wstopsig,pcntl_signal,pcntl_signal_dispatch,pcntl_get_last_error,pcntl_strerror,pcntl_sigprocmask,pcntl_sigwaitinfo,pcntl_sigtimedwait,pcntl_exec,pcntl_getpriority,pcntl_setpriority, MySQL : OFF | cURL : ON | WGET : OFF | Perl : OFF | Python : OFF | Sudo : OFF | Pkexec : OFF Directory : /var/www/www-root/data/www/dev.artlot24.ru/bitrix/modules/main/lib/data/ |
Upload File : |
<?php
namespace Bitrix\Main\Data;
use Bitrix\Main\Data\LocalStorage;
class CacheEngineXCache
implements ICacheEngine, ICacheEngineStat, LocalStorage\Storage\CacheEngineInterface
{
private $sid = "BX";
//cache stats
private $written = false;
private $read = false;
protected $useLock = false;
protected $ttlMultiplier = 2;
protected static $locks = array();
/**
* Engine constructor.
* @param array $options Cache options.
*/
function __construct($options = [])
{
$config = \Bitrix\Main\Config\Configuration::getValue("cache");
if ($config && is_array($config))
{
if (isset($config["use_lock"]))
{
$this->useLock = (bool)$config["use_lock"];
}
if (isset($config["sid"]) && ($config["sid"] != ""))
{
$this->sid = $config["sid"];
}
if (isset($config["ttl_multiplier"]) && $this->useLock)
{
$this->ttlMultiplier = (integer)$config["ttl_multiplier"];
}
}
if (!empty($options) && isset($options['actual_data']))
{
$this->useLock = !((bool) $options['actual_data']);
}
$this->sid .= !$this->useLock;
if (!$this->useLock)
{
$this->ttlMultiplier = 1;
}
}
/**
* Returns number of bytes read from xcache or false if there was no read operation.
*
* @return integer|false
*/
public function getReadBytes()
{
return $this->read;
}
/**
* Returns number of bytes written to xcache or false if there was no write operation.
*
* @return integer|false
*/
public function getWrittenBytes()
{
return $this->written;
}
/**
* Returns physical file path after read or write operation.
* Stub function always returns '' (empty string).
*
* @return string
*/
public function getCachePath()
{
return "";
}
/**
* Returns true if cache can be read or written.
*
* @return bool
*/
public function isAvailable()
{
return function_exists('xcache_get');
}
/**
* Tries to put non blocking exclusive lock on the cache entry.
* Returns true on success.
*
* @param string $baseDir Base cache directory (usually /bitrix/cache).
* @param string $initDir Directory within base.
* @param string $key Calculated cache key.
* @param integer $TTL Expiration period in seconds.
*
* @return boolean
*/
protected function lock($baseDir, $initDir, $key, $TTL)
{
if (
isset(self::$locks[$baseDir])
&& isset(self::$locks[$baseDir][$initDir])
&& isset(self::$locks[$baseDir][$initDir][$key])
)
{
return true;
}
elseif (xcache_get($key)) //another process has the lock
{
return false;
}
else
{
$lock = xcache_inc($key, 1, intval($TTL));
if ($lock === 1) //we are lucky to be the first
{
self::$locks[$baseDir][$initDir][$key] = true;
return true;
}
//xcache_dec have to be never called due to concurrency with xcache_set($key."~", 1, intval($TTL));
}
return false;
}
/**
* Releases the lock obtained by lock method.
*
* @param string $baseDir Base cache directory (usually /bitrix/cache).
* @param string $initDir Directory within base.
* @param string $key Calculated cache key.
* @param integer $TTL Expiration period in seconds.
*
* @return void
*/
protected function unlock($baseDir, $initDir = false, $key = false, $TTL = 0)
{
if ($key !== false)
{
if ($TTL > 0)
{
xcache_set($key, 1, intval($TTL));
}
else
{
xcache_unset($key);
}
unset(self::$locks[$baseDir][$initDir][$key]);
}
elseif ($initDir !== false)
{
if (isset(self::$locks[$baseDir][$initDir]))
{
foreach (self::$locks[$baseDir][$initDir] as $subKey)
{
$this->unlock($baseDir, $initDir, $subKey, $TTL);
}
unset(self::$locks[$baseDir][$initDir]);
}
}
elseif ($baseDir !== false)
{
if (isset(self::$locks[$baseDir]))
{
foreach (self::$locks[$baseDir] as $subInitDir)
{
$this->unlock($baseDir, $subInitDir, false, $TTL);
}
}
}
}
/**
* Cleans (removes) cache directory or file.
*
* @param string $baseDir Base cache directory (usually /bitrix/cache).
* @param string $initDir Directory within base.
* @param string $filename File name.
*
* @return void
*/
public function clean($baseDir, $initDir = false, $filename = false)
{
$key = false;
if($filename <> '')
{
$baseDirVersion = xcache_get($this->sid.$baseDir);
if($baseDirVersion === null)
{
return;
}
if($initDir !== false)
{
$initDirVersion = xcache_get($baseDirVersion."|".$initDir);
if($initDirVersion === null)
{
return;
}
}
else
{
$initDirVersion = "";
}
$key = $baseDirVersion."|".$initDirVersion."|".$filename;
xcache_unset($key);
}
else
{
if($initDir <> '')
{
$baseDirVersion = xcache_get($this->sid.$baseDir);
if($baseDirVersion === null)
{
return;
}
xcache_unset($baseDirVersion."|".$initDir);
}
else
{
xcache_unset($this->sid.$baseDir);
}
}
$this->unlock($baseDir, $initDir, $key."~");
}
/**
* Reads cache from the xcache. Returns true if key value exists, not expired, and successfully read.
*
* @param mixed &$allVars Cached result.
* @param string $baseDir Base cache directory (usually /bitrix/cache).
* @param string $initDir Directory within base.
* @param string $filename File name.
* @param integer $TTL Expiration period in seconds.
*
* @return boolean
*/
public function read(&$allVars, $baseDir, $initDir, $filename, $TTL)
{
$baseDirVersion = xcache_get($this->sid.$baseDir);
if ($baseDirVersion === null)
return false;
if ($initDir !== false)
{
$initDirVersion = xcache_get($baseDirVersion."|".$initDir);
if ($initDirVersion === null)
return false;
}
else
{
$initDirVersion = "";
}
$key = $baseDirVersion."|".$initDirVersion."|".$filename;
$allVars = xcache_get($key);
if ($allVars === null)
{
return false;
}
else
{
if ($this->useLock)
{
if ($this->lock($baseDir, $initDir, $key."~", $TTL))
{
return false;
}
}
$this->read = mb_strlen($allVars);
$allVars = unserialize($allVars);
}
return true;
}
/**
* Puts cache into the xcache.
*
* @param mixed $allVars Cached result.
* @param string $baseDir Base cache directory (usually /bitrix/cache).
* @param string $initDir Directory within base.
* @param string $filename File name.
* @param integer $TTL Expiration period in seconds.
*
* @return void
*/
public function write($allVars, $baseDir, $initDir, $filename, $TTL)
{
$baseDirVersion = xcache_get($this->sid.$baseDir);
if ($baseDirVersion === null)
{
$baseDirVersion = md5(mt_rand());
if (!xcache_set($this->sid.$baseDir, $baseDirVersion))
return;
}
if ($initDir !== false)
{
$initDirVersion = xcache_get($baseDirVersion."|".$initDir);
if ($initDirVersion === null)
{
$initDirVersion = md5(mt_rand());
if (!xcache_set($baseDirVersion."|".$initDir, $initDirVersion))
return;
}
}
else
{
$initDirVersion = "";
}
$allVars = serialize($allVars);
$this->written = mb_strlen($allVars);
$key = $baseDirVersion."|".$initDirVersion."|".$filename;
xcache_set($key, $allVars, intval($TTL) * $this->ttlMultiplier);
if ($this->useLock)
{
$this->unlock($baseDir, $initDir, $key."~", $TTL);
}
}
/**
* Returns true if cache has been expired.
* Stub function always returns true.
*
* @param string $path Absolute physical path.
*
* @return boolean
*/
public function isCacheExpired($path)
{
return false;
}
}