v161

Author: cheprasov

src/RedisClient/Command/Parameter/Parameter.php

@@ -91,7 +91,7 @@ public static function assocArrayFlip(array $array) {
     /**
      * @param string $operation
      * @return string
-     * @return InvalidArgumentException
+     * @throws InvalidArgumentException
      */
     public static function bitOperation($operation) {
         $operation = strtoupper((string)$operation);
@@ -134,7 +134,7 @@ public static function enum($param, array $enum) {
      * @return float
      */
     public static function float($float) {
-        return (float) $float;
+        return (float)$float;
     }
 
     /**
@@ -145,7 +145,8 @@ public static function float($float) {
 
     /**
      * @param string $unit
-     * @return string mixed
+     * @return string
+     * @throws InvalidArgumentException
      */
     public static function geoUnit($unit) {
         if (!in_array($unit, static::$geoUnits)) {
@@ -193,14 +194,15 @@ public static function keys($keys) {
     /**
      * @param int|string|int[]|string[] $limit
      * @return int[]
+     * @throws InvalidArgumentException
      */
     public static function limit($limit) {
         if (is_numeric($limit)) {
             return [0, (int)$limit];
         }
         if (is_array($limit) && isset($limit['count'])) {
             return [
-                empty($limit['offset']) ? 0: (int) $limit['offset'],
+                empty($limit['offset']) ? 0: (int)$limit['offset'],
                 (int)$limit['count'],
             ];
         }
@@ -223,6 +225,7 @@ public static function limit($limit) {
     /**
      * @param int|string $param
      * @return int|string
+     * @throws InvalidArgumentException
      */
     public static function minMax($param) {
         $param = trim($param);
@@ -235,6 +238,7 @@ public static function minMax($param) {
     /**
      * @param string $param
      * @return string
+     * @throws InvalidArgumentException
      */
     public static function nxXx($param) {
         if ($param === 'NX' || $param === 'XX') {
@@ -253,6 +257,7 @@ public static function nxXx($param) {
     /**
      * @param int|float|string $int
      * @return int
+     * @throws InvalidArgumentException
      */
     public static function port($int) {
         $int = (int)$int;
@@ -267,6 +272,7 @@ public static function port($int) {
     /**
      * @param string|int $param
      * @return string
+     * @throws InvalidArgumentException
      */
     public static function specifyInterval($param) {
         $param = trim($param);

src/RedisClient/Command/Response/ResponseParser.php

@@ -105,7 +105,7 @@ public static function parseInfo($response) {
         if (!$response) {
             return $response;
         }
-        $response = trim((string) $response);
+        $response = trim((string)$response);
         $result = [];
         $link = &$result;
         foreach (explode("\n", $response) as $line) {

src/RedisClient/Connection/StreamConnection.php

@@ -122,14 +122,18 @@ public function readLine() {
 
     /**
      * @param int $length
-     * @return string
+     * @return string|null
      */
     public function read($length) {
         $resource = $this->getResource();
         $left = $length;
         $data = '';
         do {
-            $data .= fread($resource, min($left, 8192));
+            $read = fread($resource, min($left, 8192));
+            if (false === $read) {
+                return null;
+            }
+            $data .= $read;
             $left = $length - strlen($data);
         } while ($left > 0);
 

src/RedisClient/Protocol/RedisProtocol.php

@@ -58,7 +58,7 @@ public function getConnection() {
      */
     protected function pack($data) {
         if (is_string($data) || is_int($data) || is_bool($data) || is_float($data) || is_null($data)) {
-            return $this->packProtocolBulkString((string) $data);
+            return $this->packProtocolBulkString((string)$data);
         }
         if (is_array($data)) {
             return $this->packProtocolArray($data);
@@ -119,7 +119,11 @@ protected function read() {
             if ($length === -1) {
                 return null;
             }
-            return substr($this->Connection->read($length + 2), 0, -2);
+            $read = $this->Connection->read($length + 2);
+            if (is_null($read)) {
+                throw new EmptyResponseException('Can not read response. Please, check connection timeout.');
+            }
+            return substr($read, 0, -2);
         }
 
         if ($type === self::TYPE_SIMPLE_STRINGS) {
@@ -130,7 +134,7 @@ protected function read() {
         }
 
         if ($type === self::TYPE_INTEGERS) {
-            return (int) $data;
+            return (int)$data;
         }
 
         if ($type === self::TYPE_ARRAYS) {

tests/Integration/Version3x2/ServerCommandsTest.php

@@ -22,7 +22,7 @@ class ServerCommandsTest extends \Test\Integration\Version3x0\ServerCommandsTest
      */
     public function test_commandCount() {
         $Redis = static::$Redis;
-        $this->assertSame(172, $Redis->commandCount());
+        $this->assertSame(174, $Redis->commandCount());
     }
 
     /**
@@ -49,9 +49,11 @@ public function test_command() {
             'debug',
             'echo',
             'eval',
+            'host:',
             'latency',
             'pfdebug',
             'pfselftest',
+            'post',
             'psync',
             'replconf',
             'restore-asking',