Merge pull request #11 from uniondrug/2.x

add ping()

src/Servitization/Client/Client.php

@@ -25,6 +25,22 @@ public function getProtocol()
         return $this->scheme;
     }
 
+    /**
+     * 同步客户端，已经连接过，则尝试ping一下。
+     *
+     * @return bool
+     */
+    public function ping()
+    {
+        if ($this->client->isConnected() && !$this->async) {
+            $this->client->send('ping');
+            $res = $this->receive();
+            return $res === 'pong';
+        }
+
+        return false;
+    }
+
     /**
      * @param string $data
      *
@@ -91,11 +107,11 @@ public function decodeChunked($str)
         $thisChunk = '';
 
         // Loop the data
-        while (($part = array_shift($parts)) !== NULL) {
+        while (($part = array_shift($parts)) !== null) {
             if ($chunkLen) {
                 // Add the data to the string
                 // Don't forget, the data might contain a literal CRLF
-                $thisChunk .= $part."\r\n";
+                $thisChunk .= $part . "\r\n";
                 if (strlen($thisChunk) == $chunkLen) {
                     // Chunk is complete
                     $result .= $thisChunk;
@@ -108,7 +124,7 @@ public function decodeChunked($str)
                     $thisChunk = '';
                 } else if (strlen($thisChunk) > $chunkLen) {
                     // Data is malformed
-                    return FALSE;
+                    return false;
                 }
             } else {
                 // If we are not in a chunk, get length of the new one
@@ -118,6 +134,6 @@ public function decodeChunked($str)
         }
 
         // Return the decoded data of FALSE if it is incomplete
-        return ($chunkLen) ? FALSE : $result;
+        return ($chunkLen) ? false : $result;
     }
 }

src/Servitization/Server/TCPServer.php

@@ -40,6 +40,7 @@ class TCPServer extends TCP
     public function doWork(swoole_server $server, $fd, $data, $from_id)
     {
         $data = trim($data);
+
         if ('ping' === $data) {
             $server->send($fd, 'pong');
             return 0;