@@ -31,7 +31,10 @@ abstract class CometServer extends WebSocket
      */
     function onStart($serv, $worker_id = 0)
     {
-        $serv->addTimer(1000);
+        if ($worker_id < $serv->setting['worker_num'])
+        {
+            $serv->addTimer(1000);
+        }
         parent::onStart($serv, $worker_id);
     }
 
@@ -128,7 +131,7 @@ function getSession($session_id)
     function send($session_id, $data, $opcode = self::OPCODE_TEXT_FRAME, $end = true)
     {
         //WebSocket
-        if (isset($this->connections[$session_id]))
+        if (!$this->isCometClient($session_id))
         {
             return parent::send($session_id, $data, $opcode, $end);
         }
Original file line number	Diff line number	Diff line change
@@ -31,7 +31,10 @@ abstract class CometServer extends WebSocket
31	31	*/
32	32	function onStart($serv, $worker_id = 0)
33	33	{
34		- $serv->addTimer(1000);
	34	+ if ($worker_id < $serv->setting['worker_num'])
	35	+ {
	36	+ $serv->addTimer(1000);
	37	+ }
35	38	parent::onStart($serv, $worker_id);
36	39	}
37	40
@@ -128,7 +131,7 @@ function getSession($session_id)
128	131	function send($session_id, $data, $opcode = self::OPCODE_TEXT_FRAME, $end = true)
129	132	{
130	133	//WebSocket
131		- if (isset($this->connections[$session_id]))
	134	+ if (!$this->isCometClient($session_id))
132	135	{
133	136	return parent::send($session_id, $data, $opcode, $end);
134	137	}