Implement RedisCacheSource::getCacheName()

diff --git a/wcfsetup/install/files/lib/system/cache/source/RedisCacheSource.class.php b/wcfsetup/install/files/lib/system/cache/source/RedisCacheSource.class.php
index a1ee065cb02506aedaae40672634e23244efe198..aac947eab8d329f29a3fccb69c40cb1bf02efdb4 100644 (file)
--- a/wcfsetup/install/files/lib/system/cache/source/RedisCacheSource.class.php
+++ b/wcfsetup/install/files/lib/system/cache/source/RedisCacheSource.class.php
@@ -113,4 +113,24 @@ class RedisCacheSource implements ICacheSource {
                        $this->redis->setex($cacheName, $this->getTTL($maxLifetime), serialize($value));
                }
        }
+       
+       /**
+        * Returns the name for the given cache name in respect to flush count.
+        * 
+        * @param       string          $cacheName
+        * @return      string
+        */
+       protected function getCacheName($cacheName) {
+               $flush = $this->redis->get('_flush');
+               
+               // create flush counter if it does not exist
+               if ($flush === false) {
+                       $this->redis->setnx('_flush', TIME_NOW);
+                       $this->redis->incr('_flush');
+                       
+                       $flush = $this->redis->get('_flush');
+               }
+               
+               return $flush.':'.$cacheName;
+       }
 }