|
|
@@ -252,7 +252,7 @@ class Monitor extends Man\Core\SocketWorker
|
|
|
// 将过期的消息读出来,清理掉
|
|
|
if(\Man\Core\Master::getQueueId())
|
|
|
{
|
|
|
- while(msg_receive(\Man\Core\Master::getQueueId(), self::MSG_TYPE_STATUS, $msg_type, 1000, $message, true, MSG_IPC_NOWAIT))
|
|
|
+ while(@msg_receive(\Man\Core\Master::getQueueId(), self::MSG_TYPE_STATUS, $msg_type, 1000, $message, true, MSG_IPC_NOWAIT))
|
|
|
{
|
|
|
}
|
|
|
}
|
|
|
@@ -364,7 +364,7 @@ class Monitor extends Man\Core\SocketWorker
|
|
|
*/
|
|
|
protected function getStatusFromQueue()
|
|
|
{
|
|
|
- if(msg_receive(\Man\Core\Master::getQueueId(), self::MSG_TYPE_STATUS, $msg_type, 10000, $message, true, MSG_IPC_NOWAIT))
|
|
|
+ if(@msg_receive(\Man\Core\Master::getQueueId(), self::MSG_TYPE_STATUS, $msg_type, 10000, $message, true, MSG_IPC_NOWAIT))
|
|
|
{
|
|
|
$pid = $message['pid'];
|
|
|
$worker_name = $message['worker_name'];
|