Added @ operator for fclose.

hprose · Jul 30, 2016 · 9a5bc20 · 9a5bc20
1 parent 8fc1f83
commit 9a5bc20
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 4 deletions.
diff --git a/src/Hprose/Socket/FullDuplexTransporter.php b/src/Hprose/Socket/FullDuplexTransporter.php
@@ -14,7 +14,7 @@
  *                                                        *
  * hprose socket FullDuplexTransporter class for php 5.3+ *
  *                                                        *
- * LastModified: Jul 12, 2016                             *
+ * LastModified: Jul 30, 2016                             *
  * Author: Ma Bingyao <[email protected]>                  *
  *                                                        *
 \**********************************************************/
@@ -56,7 +56,7 @@ protected function asyncReadError($o, $stream, $index) {
         }
         unset($o->queue[$stream_id]);
         unset($o->responses[$stream_id]);
-        fclose($stream);
+        @fclose($stream);
         $this->removeStream($stream, $o->readpool);
         $this->removeStream($stream, $o->writepool);
     }

diff --git a/src/Hprose/Socket/HalfDuplexTransporter.php b/src/Hprose/Socket/HalfDuplexTransporter.php
@@ -14,7 +14,7 @@
  *                                                        *
  * hprose socket HalfDuplexTransporter class for php 5.3+ *
  *                                                        *
- * LastModified: Jul 12, 2016                             *
+ * LastModified: Jul 30, 2016                             *
  * Author: Ma Bingyao <[email protected]>                  *
  *                                                        *
 \**********************************************************/
@@ -40,7 +40,7 @@ protected function asyncReadError($o, $stream, $index) {
         $o->results[$index]->reject($this->getLastError('response read error'));
         $this->free($o, $index);
         unset($o->responses[(integer)$stream]);
-        fclose($stream);
+        @fclose($stream);
         $this->removeStream($stream, $o->readpool);
     }
     protected function getBodyLength($stream) {