summaryrefslogtreecommitdiffstats
path: root/lib/private/Memcache
diff options
context:
space:
mode:
authorRobin McCorkell <robin@mccorkell.me.uk>2016-03-13 22:41:04 +0000
committerMorris Jobke <hey@morrisjobke.de>2017-03-25 21:25:27 -0600
commitef57c03dd22115ddee75c14c3c5073d924cca23a (patch)
tree4a22243968dd6fedc6640948d50489dbaced38fe /lib/private/Memcache
parent0981f9a18a7253f7a5e7f44359c3bfc5ffe0f650 (diff)
downloadnextcloud-server-ef57c03dd22115ddee75c14c3c5073d924cca23a.tar.gz
nextcloud-server-ef57c03dd22115ddee75c14c3c5073d924cca23a.zip
Add Redis Cluster support
Signed-off-by: Morris Jobke <hey@morrisjobke.de>
Diffstat (limited to 'lib/private/Memcache')
-rw-r--r--lib/private/Memcache/Redis.php28
1 files changed, 14 insertions, 14 deletions
diff --git a/lib/private/Memcache/Redis.php b/lib/private/Memcache/Redis.php
index c3184e45856..d423b134f95 100644
--- a/lib/private/Memcache/Redis.php
+++ b/lib/private/Memcache/Redis.php
@@ -49,8 +49,8 @@ class Redis extends Cache implements IMemcacheTTL {
}
public function get($key) {
- $result = self::$cache->get($this->getNamespace() . $key);
- if ($result === false && !self::$cache->exists($this->getNamespace() . $key)) {
+ $result = self::$cache->get($this->getNameSpace() . $key);
+ if ($result === false && !self::$cache->exists($this->getNameSpace() . $key)) {
return null;
} else {
return json_decode($result, true);
@@ -59,18 +59,18 @@ class Redis extends Cache implements IMemcacheTTL {
public function set($key, $value, $ttl = 0) {
if ($ttl > 0) {
- return self::$cache->setex($this->getNamespace() . $key, $ttl, json_encode($value));
+ return self::$cache->setex($this->getNameSpace() . $key, $ttl, json_encode($value));
} else {
- return self::$cache->set($this->getNamespace() . $key, json_encode($value));
+ return self::$cache->set($this->getNameSpace() . $key, json_encode($value));
}
}
public function hasKey($key) {
- return self::$cache->exists($this->getNamespace() . $key);
+ return self::$cache->exists($this->getNameSpace() . $key);
}
public function remove($key) {
- if (self::$cache->delete($this->getNamespace() . $key)) {
+ if (self::$cache->delete($this->getNameSpace() . $key)) {
return true;
} else {
return false;
@@ -78,7 +78,7 @@ class Redis extends Cache implements IMemcacheTTL {
}
public function clear($prefix = '') {
- $prefix = $this->getNamespace() . $prefix . '*';
+ $prefix = $this->getNameSpace() . $prefix . '*';
$it = null;
self::$cache->setOption(\Redis::OPT_SCAN, \Redis::SCAN_RETRY);
while ($keys = self::$cache->scan($it, $prefix)) {
@@ -111,7 +111,7 @@ class Redis extends Cache implements IMemcacheTTL {
* @return int | bool
*/
public function inc($key, $step = 1) {
- return self::$cache->incrBy($this->getNamespace() . $key, $step);
+ return self::$cache->incrBy($this->getNameSpace() . $key, $step);
}
/**
@@ -125,7 +125,7 @@ class Redis extends Cache implements IMemcacheTTL {
if (!$this->hasKey($key)) {
return false;
}
- return self::$cache->decrBy($this->getNamespace() . $key, $step);
+ return self::$cache->decrBy($this->getNameSpace() . $key, $step);
}
/**
@@ -140,10 +140,10 @@ class Redis extends Cache implements IMemcacheTTL {
if (!is_int($new)) {
$new = json_encode($new);
}
- self::$cache->watch($this->getNamespace() . $key);
+ self::$cache->watch($this->getNameSpace() . $key);
if ($this->get($key) === $old) {
$result = self::$cache->multi()
- ->set($this->getNamespace() . $key, $new)
+ ->set($this->getNameSpace() . $key, $new)
->exec();
return ($result === false) ? false : true;
}
@@ -159,10 +159,10 @@ class Redis extends Cache implements IMemcacheTTL {
* @return bool
*/
public function cad($key, $old) {
- self::$cache->watch($this->getNamespace() . $key);
+ self::$cache->watch($this->getNameSpace() . $key);
if ($this->get($key) === $old) {
$result = self::$cache->multi()
- ->del($this->getNamespace() . $key)
+ ->del($this->getNameSpace() . $key)
->exec();
return ($result === false) ? false : true;
}
@@ -171,7 +171,7 @@ class Redis extends Cache implements IMemcacheTTL {
}
public function setTTL($key, $ttl) {
- self::$cache->expire($this->getNamespace() . $key, $ttl);
+ self::$cache->expire($this->getNameSpace() . $key, $ttl);
}
static public function isAvailable() {