Merge pull request #3387 from kdambekalns/task/use-scan-for-redis-flush

TASK: Use `SCAN` for redis flush
neos · Nov 8, 2024 · 10cdecd · 10cdecd
2 parents 87c6087 + 48381d2
commit 10cdecd
Showing 1 changed file with 9 additions and 4 deletions.
diff --git a/Neos.Cache/Classes/Backend/RedisBackend.php b/Neos.Cache/Classes/Backend/RedisBackend.php
@@ -233,10 +233,15 @@ public function flush(): void
     {
         // language=lua
         $script = "
-        local keys = redis.call('KEYS', ARGV[1] .. '*')
-        for k1,key in ipairs(keys) do
-            redis.call('DEL', key)
-        end
+        local cursor = '0'
+        repeat
+            local result = redis.call('SCAN', cursor, 'MATCH', ARGV[1] .. '*')
+            cursor = result[1]
+            local keys = result[2]
+            for _, key in ipairs(keys) do
+                redis.call('DEL', key)
+            end
+        until cursor == '0'
         ";
         $this->redis->eval($script, [$this->getPrefixedIdentifier('')], 0);