summaryrefslogtreecommitdiffstats
path: root/lib
diff options
context:
space:
mode:
authorRobin Appelman <icewind@owncloud.com>2015-06-08 15:25:23 +0200
committerRobin Appelman <icewind@owncloud.com>2015-06-12 17:28:09 +0200
commitac9f998abdceb21fbbda4e8dee0e8b16c2f5ec4e (patch)
tree844d7641ee0bc74edc874af3a0418cf175ac2b53 /lib
parent1bc56a99e9e368091753ff79facf930336478a35 (diff)
downloadnextcloud-server-ac9f998abdceb21fbbda4e8dee0e8b16c2f5ec4e.tar.gz
nextcloud-server-ac9f998abdceb21fbbda4e8dee0e8b16c2f5ec4e.zip
add compare-and-delete to the memcache interface
Diffstat (limited to 'lib')
-rw-r--r--lib/private/memcache/apc.php2
-rw-r--r--lib/private/memcache/arraycache.php2
-rw-r--r--lib/private/memcache/cadtrait.php53
-rw-r--r--lib/private/memcache/memcached.php2
-rw-r--r--lib/private/memcache/nullcache.php4
-rw-r--r--lib/private/memcache/xcache.php2
-rw-r--r--lib/public/imemcache.php10
7 files changed, 75 insertions, 0 deletions
diff --git a/lib/private/memcache/apc.php b/lib/private/memcache/apc.php
index 50b942e7297..f768cdc1c6e 100644
--- a/lib/private/memcache/apc.php
+++ b/lib/private/memcache/apc.php
@@ -31,6 +31,8 @@ class APC extends Cache implements IMemcache {
cas as casEmulated;
}
+ use CADTrait;
+
public function get($key) {
$result = apc_fetch($this->getPrefix() . $key, $success);
if (!$success) {
diff --git a/lib/private/memcache/arraycache.php b/lib/private/memcache/arraycache.php
index 2b1b87a9eb3..8a3fdd2f7c5 100644
--- a/lib/private/memcache/arraycache.php
+++ b/lib/private/memcache/arraycache.php
@@ -28,6 +28,8 @@ class ArrayCache extends Cache implements IMemcache {
/** @var array Array with the cached data */
protected $cachedData = array();
+ use CADTrait;
+
/**
* {@inheritDoc}
*/
diff --git a/lib/private/memcache/cadtrait.php b/lib/private/memcache/cadtrait.php
new file mode 100644
index 00000000000..e9836e24040
--- /dev/null
+++ b/lib/private/memcache/cadtrait.php
@@ -0,0 +1,53 @@
+<?php
+/**
+ * @author Robin Appelman <icewind@owncloud.com>
+ *
+ * @copyright Copyright (c) 2015, ownCloud, Inc.
+ * @license AGPL-3.0
+ *
+ * This code is free software: you can redistribute it and/or modify
+ * it under the terms of the GNU Affero General Public License, version 3,
+ * as published by the Free Software Foundation.
+ *
+ * This program is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
+ * GNU Affero General Public License for more details.
+ *
+ * You should have received a copy of the GNU Affero General Public License, version 3,
+ * along with this program. If not, see <http://www.gnu.org/licenses/>
+ *
+ */
+
+namespace OC\Memcache;
+
+trait CADTrait {
+ abstract public function get($key);
+
+ abstract public function remove($key);
+
+ abstract public function add($key, $value, $ttl = 0);
+
+ /**
+ * Compare and delete
+ *
+ * @param string $key
+ * @param mixed $old
+ * @return bool
+ */
+ public function cad($key, $old) {
+ //no native cas, emulate with locking
+ if ($this->add($key . '_lock', true)) {
+ if ($this->get($key) === $old) {
+ $this->remove($key);
+ $this->remove($key . '_lock');
+ return true;
+ } else {
+ $this->remove($key . '_lock');
+ return false;
+ }
+ } else {
+ return false;
+ }
+ }
+}
diff --git a/lib/private/memcache/memcached.php b/lib/private/memcache/memcached.php
index cf1d651b551..1503851fd73 100644
--- a/lib/private/memcache/memcached.php
+++ b/lib/private/memcache/memcached.php
@@ -34,6 +34,8 @@ class Memcached extends Cache implements IMemcache {
*/
private static $cache = null;
+ use CADTrait;
+
public function __construct($prefix = '') {
parent::__construct($prefix);
if (is_null(self::$cache)) {
diff --git a/lib/private/memcache/nullcache.php b/lib/private/memcache/nullcache.php
index 77eadba4eba..f971ffc9b2d 100644
--- a/lib/private/memcache/nullcache.php
+++ b/lib/private/memcache/nullcache.php
@@ -55,6 +55,10 @@ class NullCache extends Cache implements \OCP\IMemcache {
return true;
}
+ public function cad($key, $old) {
+ return true;
+ }
+
public function clear($prefix = '') {
return true;
}
diff --git a/lib/private/memcache/xcache.php b/lib/private/memcache/xcache.php
index 0be79d06ed9..a6265ed5622 100644
--- a/lib/private/memcache/xcache.php
+++ b/lib/private/memcache/xcache.php
@@ -34,6 +34,8 @@ use OCP\IMemcache;
class XCache extends Cache implements IMemcache {
use CASTrait;
+ use CADTrait;
+
/**
* entries in XCache gets namespaced to prevent collisions between ownCloud instances and users
*/
diff --git a/lib/public/imemcache.php b/lib/public/imemcache.php
index f8b898e54c6..a1a00791b63 100644
--- a/lib/public/imemcache.php
+++ b/lib/public/imemcache.php
@@ -76,4 +76,14 @@ interface IMemcache extends ICache {
* @since 8.1.0
*/
public function cas($key, $old, $new);
+
+ /**
+ * Compare and delete
+ *
+ * @param string $key
+ * @param mixed $old
+ * @return bool
+ * @since 8.1.0
+ */
+ public function cad($key, $old);
}