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)
171
171
0 TSRMLS_CC );
172
172
}
173
173
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
+ }
187
187
redis_sock_connect (redis_sock TSRMLS_CC ); /* reconnect */
188
188
if (redis_sock -> stream ) { /* check for EOF again. */
189
189
errno = 0 ;
You can’t perform that action at this time.
0 commit comments