File tree Expand file tree Collapse file tree 1 file changed +13
-13
lines changed Expand file tree Collapse file tree 1 file changed +13
-13
lines changed Original file line number Diff line number Diff line change @@ -171,19 +171,19 @@ PHP_REDIS_API int redis_check_eof(RedisSock *redis_sock, int no_throw TSRMLS_DC)
171171 0 TSRMLS_CC );
172172 }
173173 return -1 ;
174- }
175- if (redis_sock -> stream ) { /* close existing stream before reconnecting */
176- redis_stream_close (redis_sock TSRMLS_CC );
177- redis_sock -> stream = NULL ;
178- redis_sock -> mode = ATOMIC ;
179- redis_sock -> watching = 0 ;
180- }
181- // Wait for a while before trying to reconnect
182- if (redis_sock -> retry_interval ) {
183- // Random factor to avoid having several (or many) concurrent connections trying to reconnect at the same time
184- long retry_interval = (count ? redis_sock -> retry_interval : (php_rand (TSRMLS_C ) % redis_sock -> retry_interval ));
185- usleep (retry_interval );
186- }
174+ }
175+ if (redis_sock -> stream ) { /* close existing stream before reconnecting */
176+ redis_stream_close (redis_sock TSRMLS_CC );
177+ redis_sock -> stream = NULL ;
178+ redis_sock -> mode = ATOMIC ;
179+ redis_sock -> watching = 0 ;
180+ }
181+ // Wait for a while before trying to reconnect
182+ if (redis_sock -> retry_interval ) {
183+ // Random factor to avoid having several (or many) concurrent connections trying to reconnect at the same time
184+ long retry_interval = (count ? redis_sock -> retry_interval : (php_rand (TSRMLS_C ) % redis_sock -> retry_interval ));
185+ usleep (retry_interval );
186+ }
187187 redis_sock_connect (redis_sock TSRMLS_CC ); /* reconnect */
188188 if (redis_sock -> stream ) { /* check for EOF again. */
189189 errno = 0 ;
You can’t perform that action at this time.
0 commit comments