diff --git a/src/Hprose/Socket/FullDuplexTransporter.php b/src/Hprose/Socket/FullDuplexTransporter.php index 1f28e0ee..1d45bfd4 100644 --- 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 * * * \**********************************************************/ @@ -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 index 260de9ca..b45b0c23 100644 --- 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 * * * \**********************************************************/ @@ -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) {