[Cache] Make use of read_timeout in \RedisSentinel and \Redis

ferrastas · ferrastas · commit 14e36a22d69a · 2020-12-10T16:38:46.000+01:00
Both classes have an optional argument `$readTimeout` that can be set during
initialization for `\RedisSentinel` and during `connect`/`pconnect`
respectively.
diff --git a/src/Symfony/Component/Cache/Traits/RedisTrait.php b/src/Symfony/Component/Cache/Traits/RedisTrait.php
@@ -184,15 +184,15 @@ public static function createConnection($dsn, array $options = [])
                 $port = $hosts[0]['port'] ?? null;
 
                 if (isset($params['redis_sentinel'])) {
-                    $sentinel = new \RedisSentinel($host, $port, $params['timeout'], (string) $params['persistent_id'], $params['retry_interval']);
+                    $sentinel = new \RedisSentinel($host, $port, $params['timeout'], (string) $params['persistent_id'], $params['retry_interval'], $params['read_timeout']);
 
                     if (![$host, $port] = $sentinel->getMasterAddrByName($params['redis_sentinel'])) {
                         throw new InvalidArgumentException(sprintf('Failed to retrieve master information from master name "%s" and address "%s:%d".', $params['redis_sentinel'], $host, $port));
                     }
                 }
 
                 try {
-                    @$redis->{$connect}($host, $port, $params['timeout'], (string) $params['persistent_id'], $params['retry_interval']);
+                    @$redis->{$connect}($host, $port, $params['timeout'], (string) $params['persistent_id'], $params['retry_interval'], $params['read_timeout']);
 
                     set_error_handler(function ($type, $msg) use (&$error) { $error = $msg; });
                     $isConnected = $redis->isConnected();

Original file line number	Diff line number	Diff line change
`@@ -184,15 +184,15 @@ public static function createConnection($dsn, array $options = [])`
`184`	`184`	`$port = $hosts[0]['port'] ?? null;`
`185`	`185`
`186`	`186`	`if (isset($params['redis_sentinel'])) {`
`187`		`- $sentinel = new \RedisSentinel($host, $port, $params['timeout'], (string) $params['persistent_id'], $params['retry_interval']);`
	`187`	`+ $sentinel = new \RedisSentinel($host, $port, $params['timeout'], (string) $params['persistent_id'], $params['retry_interval'], $params['read_timeout']);`
`188`	`188`
`189`	`189`	`if (![$host, $port] = $sentinel->getMasterAddrByName($params['redis_sentinel'])) {`
`190`	`190`	`throw new InvalidArgumentException(sprintf('Failed to retrieve master information from master name "%s" and address "%s:%d".', $params['redis_sentinel'], $host, $port));`
`191`	`191`	`}`
`192`	`192`	`}`
`193`	`193`
`194`	`194`	`try {`
`195`		`- @$redis->{$connect}($host, $port, $params['timeout'], (string) $params['persistent_id'], $params['retry_interval']);`
	`195`	`+ @$redis->{$connect}($host, $port, $params['timeout'], (string) $params['persistent_id'], $params['retry_interval'], $params['read_timeout']);`
`196`	`196`
`197`	`197`	`set_error_handler(function ($type, $msg) use (&$error) { $error = $msg; });`
`198`	`198`	`$isConnected = $redis->isConnected();`