perdedora/leftypol
1
0
Fork 0
forked from leftypol/leftypol
Code Pull requests Activity

MemcacheCacheDriver.php: fix configuration

Browse source
This commit is contained in:
Zankaria 2025-05-29 23:55:04 +02:00
parent b9a29927f3
commit 37e771f0be
1 changed files with 31 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

34
inc/Data/Driver/MemcacheCacheDriver.php
View file

@ -5,9 +5,12 @@ defined('TINYBOARD') or exit;
class MemcachedCacheDriver implements CacheDriver { class MemcachedCacheDriver implements CacheDriver {
use CacheDriverTrait;
private \Memcached $inner; private \Memcached $inner;
public function __construct(string $prefix, string $memcached_server) {
public function __construct(string $prefix, string $server_uri, int $server_port, int $server_weight) {
$this->inner = new \Memcached(); $this->inner = new \Memcached();
if (!$this->inner->setOption(\Memcached::OPT_BINARY_PROTOCOL, true)) { if (!$this->inner->setOption(\Memcached::OPT_BINARY_PROTOCOL, true)) {
throw new \RuntimeException('Unable to set the memcached protocol!'); throw new \RuntimeException('Unable to set the memcached protocol!');
@ -15,8 +18,33 @@ class MemcachedCacheDriver implements CacheDriver {
if (!$this->inner->setOption(\Memcached::OPT_PREFIX_KEY, $prefix)) { if (!$this->inner->setOption(\Memcached::OPT_PREFIX_KEY, $prefix)) {
throw new \RuntimeException('Unable to set the memcached prefix!'); throw new \RuntimeException('Unable to set the memcached prefix!');
} }
if (!$this->inner->addServers($memcached_server)) {
throw new \RuntimeException('Unable to add the memcached server!'); $maybe_unix_path = self::asUnixSocketPath($server_uri);
$is_unix = $maybe_unix_path !== null;
if ($is_unix) {
$server_uri = $maybe_unix_path;
}
// Memcached keeps the server connections open across requests.
$current_servers = $this->inner->getServerList();
$found_in_curr = false;
foreach ($current_servers as $curr) {
// Ignore the port if the server is connected with a unix socket.
if ($curr['host'] === $server_uri && ($is_unix || $curr['port'] === $server_port)) {
$found_in_curr = true;
}
}
if (!$found_in_curr) {
if (!empty($current_servers)) {
if ($this->inner->resetServerList()) {
throw new \RuntimeException('Unable to reset the memcached server list!');
}
if ($this->inner->addServer($server_uri, $server_port, $server_weight)) {
throw new \RuntimeException('Unable to add memcached servers!');
}
}
} }
} }