Fix script running for RedisCluster

dciprian-petrisor · Oct 10, 2024 · a3ea15c · a3ea15c
1 parent e67c2a1
commit a3ea15c
Showing 1 changed file with 14 additions and 2 deletions.
diff --git a/src/Symfony/Component/Lock/Store/RedisStore.php b/src/Symfony/Component/Lock/Store/RedisStore.php
@@ -237,7 +237,13 @@ private function evaluate(string $script, string $resource, array $args): mixed
             if (null !== ($err = $this->redis->getLastError()) && self::NO_SCRIPT_ERROR_MESSAGE === $err) {
                 $this->redis->clearLastError();
 
-                $this->redis->script('LOAD', $script);
+                if ($this->redis instanceof \RedisCluster) {
+                    foreach ($this->redis->_masters() as $master) {
+                        $this->redis->script($master, 'LOAD', $script);
+                    }
+                } else {
+                    $this->redis->script('LOAD', $script);
+                }
 
                 if (null !== ($err = $this->redis->getLastError())) {
                     throw new LockStorageException($err);
@@ -260,7 +266,13 @@ private function evaluate(string $script, string $resource, array $args): mixed
             if (null !== ($err = $client->getLastError()) && self::NO_SCRIPT_ERROR_MESSAGE === $err) {
                 $client->clearLastError();
 
-                $client->script('LOAD', $script);
+                if ($this->redis instanceof \RedisCluster) {
+                    foreach ($this->redis->_masters() as $master) {
+                        $this->redis->script($master, 'LOAD', $script);
+                    }
+                } else {
+                    $this->redis->script('LOAD', $script);
+                }
 
                 if (null !== ($err = $client->getLastError())) {
                     throw new LockStorageException($err);