Fix timeout

Author: sy-records

src/BaseRedis.php

@@ -41,13 +41,6 @@ public function brPop($keys, $timeout)
     {
         $this->connection = $this->pool->getConnection();
 
-        if ($timeout === 0) {
-            // TODO Need to optimize...
-            $timeout = 99999999999;
-        }
-
-        $this->connection->setOption(\Redis::OPT_READ_TIMEOUT, (string) $timeout);
-
         $data = [];
 
         try {
@@ -61,8 +54,6 @@ public function brPop($keys, $timeout)
             }
         }
 
-        $this->connection->setOption(\Redis::OPT_READ_TIMEOUT, (string) $this->pool->getConfig()['time_out']);
-
         $this->pool->close($this->connection);
 
         return $data;
@@ -72,13 +63,6 @@ public function blPop($keys, $timeout)
     {
         $this->connection = $this->pool->getConnection();
 
-        if ($timeout === 0) {
-            // TODO Need to optimize...
-            $timeout = 99999999999;
-        }
-
-        $this->connection->setOption(\Redis::OPT_READ_TIMEOUT, (string) $timeout);
-
         $data = [];
 
         try {
@@ -92,8 +76,6 @@ public function blPop($keys, $timeout)
             }
         }
 
-        $this->connection->setOption(\Redis::OPT_READ_TIMEOUT, (string) $this->pool->getConfig()['time_out']);
-
         $this->pool->close($this->connection);
 
         return $data;
@@ -123,8 +105,6 @@ public function brpoplpush($srcKey, $dstKey, $timeout)
     {
         $this->connection = $this->pool->getConnection();
 
-        $this->connection->setOption(\Redis::OPT_READ_TIMEOUT, (string) $timeout);
-
         try {
             $start = time();
             $data = $this->connection->brpoplpush($srcKey, $dstKey, $timeout);
@@ -136,8 +116,6 @@ public function brpoplpush($srcKey, $dstKey, $timeout)
             $data = false;
         }
 
-        $this->connection->setOption(\Redis::OPT_READ_TIMEOUT, (string) $this->pool->getConfig()['time_out']);
-
         $this->pool->close($this->connection);
 
         return $data;