Ver Fonte

delete Recv_Timeout

walkor há 12 anos atrás
pai
commit
d9e12883fb
1 ficheiros alterados com 8 adições e 14 exclusões
  1. 8 14
      man/Core/SocketWorker.php

+ 8 - 14
man/Core/SocketWorker.php

@@ -350,23 +350,17 @@ abstract class SocketWorker extends AbstractWorker
         // 出错了
         if('' == $buffer)
         {
-            if(feof($connection))
+            if(!feof($connection))
             {
-                // 客户端提前断开链接
-                $this->statusInfo['client_close']++;
-                // 如果该链接对应的buffer有数据,说明放生错误
-                if(!empty($this->recvBuffers[$fd]['buf']))
-                {
-                    $this->notice("CLIENT_CLOSE\nCLIENT_IP:".$this->getRemoteIp()."\nBUFFER:[".var_export($this->recvBuffers[$fd]['buf'],true)."]\n");
-                }
+                continue;
             }
-            else
+            
+            // 客户端提前断开链接
+            $this->statusInfo['client_close']++;
+            // 如果该链接对应的buffer有数据,说明放生错误
+            if(!empty($this->recvBuffers[$fd]['buf']))
             {
-                // 如果该链接对应的buffer有数据,说明放生错误
-                if(!empty($this->recvBuffers[$fd]['buf']))
-                {
-                    $this->notice("RECV_TIMEOUT\nCLIENT_IP:".$this->getRemoteIp()."\nBUFFER:[".var_export($this->recvBuffers[$fd]['buf'],true)."]\n");
-                }
+                $this->notice("CLIENT_CLOSE\nCLIENT_IP:".$this->getRemoteIp()."\nBUFFER:[".var_export($this->recvBuffers[$fd]['buf'],true)."]\n");
             }
             
             // 关闭链接