Improved read & write

hprose · Dec 21, 2016 · eac0588 · eac0588
1 parent 0715c60
commit eac0588
Showing 1 changed file with 9 additions and 5 deletions.
diff --git a/src/Hprose/Socket/Service.php b/src/Hprose/Socket/Service.php
@@ -14,7 +14,7 @@
  *                                                        *
  * hprose socket Service library for php 5.3+             *
  *                                                        *
- * LastModified: Sep 17, 2016                             *
+ * LastModified: Dec 21, 2016                             *
  * Author: Ma Bingyao <[email protected]>                  *
  *                                                        *
 \**********************************************************/
@@ -248,12 +248,16 @@ private function accept($server) {
         $this->onReceives[(int)$socket] = $this->getOnReceive($server, $socket);
     }
     private function read($socket) {
-        $onReceive = $this->onReceives[(int)$socket];
-        $onReceive();
+        if (isset($this->onReceives[(int)$socket])) {
+            $onReceive = $this->onReceives[(int)$socket];
+            $onReceive();
+        }
     }
     private function write($socket) {
-        $onSend = $this->onSends[(int)$socket];
-        $onSend();
+        if (isset($this->onSends[(int)$socket])) {
+            $onSend = $this->onSends[(int)$socket];
+            $onSend();
+        }
     }
     private function close($socket, $context) {
         $this->removeSocket($this->writeableSockets, $socket);