process_timeout recv_timeout

man/Core/SocketWorker.php

@@ -112,8 +112,6 @@ abstract class SocketWorker extends AbstractWorker
     protected $statusInfo = array(
         'start_time'      => 0, // 该进程开始时间戳
         'total_request'   => 0, // 该进程处理的总请求数
-        'recv_timeout'    => 0, // 该进程接收数据超时总数
-        'proc_timeout'    => 0, // 该进程逻辑处理超时总数
         'packet_err'      => 0, // 该进程收到错误数据包的总数
         'throw_exception' => 0, // 该进程逻辑处理时收到异常的总数
         'thunder_herd'    => 0, // 该进程受惊群效应影响的总数
@@ -364,8 +362,6 @@ abstract class SocketWorker extends AbstractWorker
             }
             else
             {
-                // 超时了
-                $this->statusInfo['recv_timeout']++;
                 // 如果该链接对应的buffer有数据，说明放生错误
                 if(!empty($this->recvBuffers[$fd]['buf']))
                 {

workers/Monitor.php

@@ -283,7 +283,7 @@ class Monitor extends Man\Core\SocketWorker
                 }
                 
                 $this->sendToClient("---------------------------------------PROCESS STATUS-------------------------------------------\n");
-                $this->sendToClient("pid\tmemory  ".str_pad('    listening', $this->maxAddressLength)." timestamp  ".str_pad('worker_name', $this->maxWorkerNameLength)." ".str_pad('total_request', 13)." ".str_pad('recv_timeout', 12)." ".str_pad('proc_timeout',12)." ".str_pad('packet_err', 10)." ".str_pad('thunder_herd', 12)." ".str_pad('client_close', 12)." ".str_pad('send_fail', 9)." ".str_pad('throw_exception', 15)." suc/total\n");
+                $this->sendToClient("pid\tmemory  ".str_pad('    listening', $this->maxAddressLength)." timestamp  ".str_pad('worker_name', $this->maxWorkerNameLength)." ".str_pad('total_request', 13)." ".str_pad('packet_err', 10)." ".str_pad('thunder_herd', 12)." ".str_pad('client_close', 12)." ".str_pad('send_fail', 9)." ".str_pad('throw_exception', 15)." suc/total\n");
                 if(!\Man\Core\Master::getQueueId())
                 {
                     return;
@@ -380,7 +380,7 @@ class Monitor extends Man\Core\SocketWorker
             $str = "$pid\t".str_pad(round($message['memory']/(1024*1024),2)."M", 7)." " .str_pad($address,$this->maxAddressLength) ." ". $message['start_time'] ." ".str_pad($worker_name, $this->maxWorkerNameLength)." ";
             if($message)
             {
-                $str = $str . str_pad($message['total_request'], 14)." ".str_pad($message['recv_timeout'], 12)." ".str_pad($message['proc_timeout'],12)." ".str_pad($message['packet_err'],10)." ".str_pad($message['thunder_herd'],12)." ".str_pad($message['client_close'], 12)." ".str_pad($message['send_fail'],9)." ".str_pad($message['throw_exception'],15)." ".($message['total_request'] == 0 ? 100 : (round(($message['total_request']-($message['proc_timeout']+$message['packet_err']+$message['send_fail']))/$message['total_request'], 6)*100))."%";
+                $str = $str . str_pad($message['total_request'], 14)." ".str_pad($message['packet_err'],10)." ".str_pad($message['thunder_herd'],12)." ".str_pad($message['client_close'], 12)." ".str_pad($message['send_fail'],9)." ".str_pad($message['throw_exception'],15)." ".($message['total_request'] == 0 ? 100 : (round(($message['total_request']-($message['packet_err']+$message['send_fail']))/$message['total_request'], 6)*100))."%";
             }
             else
             {