//  функция выполняется в дочернем процессе после fork-a
//
//
function server_loop($address, $port, $runCmdString){

	$socket = stream_socket_server("tcp://$address:$port", $errno, $errstr);
	
	if (!$socket) {	die("$errstr ($errno)\n");	}
	
	$proc = proc_open( $runCmdString
					,array(	array("pipe","r"),
							array("pipe","w"),
							array("pipe","w"))
					, $pipes);	

	if (!is_resource($proc)){ die("Could not start process\n");	}

	fclose($pipes[0]);
	
	stream_set_blocking( $pipes[1], 0 );
	stream_set_blocking( $socket,   0 );

	$connects = array();

	while (true) {
	
		//формируем массив прослушиваемых сокетов:
		$write= $connects; 
		$read = $connects;
		$read []= $socket;
		$read []= $pipes[ 1 ];
		
		$except = null;		

		if (!stream_select($read, $write, $except, null)) { // ожидаем доступные сокеты
			break;
		}

		if (in_array($socket, $read)) {//есть новое соединение
			//принимаем новое соединение и производим рукопожатие:

			if (($connect = stream_socket_accept($socket, -1)) 
			&&  ($info = handshake($connect))) {
				$connects[] =  $connect;//добавляем его в список необходимых для обработки
				onOpen($connect, $info);//вызываем пользовательский сценарий
			}
			
			unset($read[ array_search($socket, $read) ]);
		 }
		

		if (in_array($pipes[ 1 ], $read)) {	

 			$procOutput = fgets($pipes[1]);                     //есть данные на выходе канала скрипта
			$numSent	 = 0;
					
			foreach($connects as $connect) {			//обрабатываем все соединения
				dataSend($connect, "$procOutput");	//отправляем данные клиентам
				$numSent++;
			}
			
			echo "\n $numSent time(s) sent to clients [$procOutput]";
			
			unset( $read[ array_search($pipes[ 1 ], $read) ] );
			

			if ( feof($pipes[1]) )                                   // достигнут конец данных, выходим
				break;
			
		}
		

		foreach($read as $connect) {//обрабатываем все соединения
			$data = fread($connect, 100000);

			if (!$data) { //соединение было закрыто
				fclose($connect);
				unset($connects[ array_search($connect, $connects) ]);
				
				onClose($connect);//вызываем пользовательский сценарий
				continue;
			}

			onMessage($connect, $data);	//вызываем пользовательский сценарий
		}

	}
	
	fclose($socket);
	fclose($pipes[1]);
	
	proc_close( $proc );
}



function dataSend($connect, $strSend="") {

    $sw = encode( "Output|".gmdate("Y-m-d\TH:i:s\Z")."| $strSend");

    for ($written = 0;  $written < strlen($sw); $written += $fwrite) {

        $fwrite = fwrite($connect, substr($sw,  $written, 16));

        if ($fwrite === false) {
            return $written;
        }
    }
	
	return $written;
}

	foreach($connects as $connect) {		//обрабатываем все соединения
			dataSend($connect, "Test");		//отправляем строку клиентам
			$numSent++;
		}	
		sleep(1); if (!$numloops--) break;