swoole add fread

classes/fpf/thrift/TPhpStream.php

@@ -66,7 +66,7 @@ class TPhpStream extends TTransport
     public function open()
     {
         if ($this->read_) {
-            if (defined('IS_SWOOLE_SERVICE') && true === IS_SWOOLE_SERVICE) {
+            if (defined('IS_SWOOLE_SERVICE') && IS_SWOOLE_SERVICE === true) {
                 $this->inStream_ = $this->fd;
             } else {
                 $this->inStream_ = @fopen(self::inStreamName(), 'r');
@@ -103,26 +103,23 @@ class TPhpStream extends TTransport
     public function read($len)
     {
         if (defined('IS_SWOOLE_SERVICE') && IS_SWOOLE_SERVICE === true) {
-            fseek($fp, $len);
-            $data = co::fread($fp);
+            $cur = ftell($this->inStream_);
+            $data = co::fread($this->inStream_, $len);
+            fseek($this->inStream_, $len, SEEK_CUR);
+            $data = TStringFuncFactory::create()->substr($data, 0, $len);
         } else {
             $data = @fread($this->inStream_, $len);
         }
         if ($data === false || $data === '') {
             throw new TException('TPhpStream: Could not read ' . $len . ' bytes');
         }
-
         return $data;
     }
 
     public function write($buf)
     {
         while (TStringFuncFactory::create()->strlen($buf) > 0) {
-            if (defined('IS_SWOOLE_SERVICE') && IS_SWOOLE_SERVICE === true) {
-                $got = co::fwrite($this->outStream_, $buf);
-            } else {
-                $got = @fwrite($this->outStream_, $buf);
-            }
+            $got = @fwrite($this->outStream_, $buf);
             if ($got === 0 || $got === false) {
                 throw new TException(
                     'TPhpStream: Could not write ' . TStringFuncFactory::create()->strlen($buf) . ' bytes'