[p2p] Проблема с организацией потоков

[AlexCooper]

Здравствуйте.
Пишу р2р-шный камчат, проблемы возникают при созданию обратного слушателя "сидера" от "пира".

Сид
public function initConnection():void{

trace('initconnect');

nc = new NetConnection();
nc.addEventListener(NetStatusEvent.NET_STATUS,ncStatus);
nc.connect(SERVER_ADDRESS+DEVELOPER_KEY);
}

public function ncStatus(event:NetStatusEvent):void{

trace(event.info.code);

myPeerID = nc.nearID;

initSendStream();
}

public function initSendStream():void{

trace("initSendStream");

sendStream = new NetStream(nc,NetStream.DIRECT_CONNECTIONS);
sendStream.addEventListener(NetStatusEvent.NET_STATUS, netStatusHandler);
sendStream.publish(myPeerID);

var sendStreamClient:Object = new Object();

sendStreamClient.onPeerConnect = function(callerns:NetStream):Boolean{


farPeerID = callerns.farID;

trace("onPeerConnect "+farPeerID);
initRecvStream();
//var metaData:Object = new Object();
//metaData.title = "myStream";
//metaData.width = Camera.getCamera().width;
//metaData.height = Camera.getCamera().height;

//sendStream.send("@setDataFrame", "onMetaData", metaData);

return true;
}

sendStream.client = sendStreamClient;

}

public function initRecvStream():void{

recvStream = new NetStream(nc,farPeerID);
recvStream.addEventListener(NetStatusEvent.NET_STATUS,netStatusHandler2);
recvStream.play("c-channel");
var r = new Object();
recvStream.client = r;

}

public function receiveSomeData(str:String):void{
email.text=str;
}

public function sendSomeData():void{
//sendStream.send("receiveSomeData",txtSendData.text);
//txtSendData.text='';
}

public function netStatusHandler2(event:NetStatusEvent):void{
//trace("reciver");
//trace(event.info.code);
}
public function netStatusHandler(event:NetStatusEvent):void{
trace(event.info.code);

if (event.info.code == "NetConnection.Connect.Success") {
trace('softid');
}

if (event.info.code == "NetStream.Publish.Start")
{
if (stats!='set')
{
stats='set';


sendStream.attachCamera( Camera.getCamera() );
sendStream.attachAudio( Microphone.getMicrophone() );

softid = (_sharedObj.data.softid) ? _sharedObj.data.softid: "";

var loader:URLLoader = new URLLoader();

loader.addEventListener( Event.COMPLETE, servComplete );

loader.dataFormat = URLLoaderDataFormat.VARIABLES;

trace("***Publish start\n***");
trace("SoftID -> "+softid);
trace("StreamID -> "+nc.nearID);

//loader.load( new URLRequest("http://localhost/demo/setid.php?softid="+softid+"&streamid="+nc.nearID+"&email="+email.text ) );

}
}


}
Пир

function initConnection():void{

trace('initconnect');

if(peep!=""){
farPeerID = peep;
}
nc = new NetConnection();
nc.addEventListener(NetStatusEvent.NET_STATUS,ncStatus);
nc.connect(SERVER_ADDRESS+DEVELOPER_KEY);
}

function ncStatus(event:NetStatusEvent):void{

trace(event.info.code);

myPeerID = nc.nearID;

txtFingerprint.text = myPeerID;
initSendStream();
initRecvStream();

}

function initSendStream():void{

trace("initSendStream");

sendStream = new NetStream(nc,NetStream.DIRECT_CONNECTIONS);
sendStream.addEventListener(NetStatusEvent.NET_STATUS, netStatusHandler);
sendStream.publish("c-channel");

var sendStreamClient:Object = new Object();

sendStreamClient.onPeerConnect = function(callerns:NetStream):Boolean{

farPeerID = callerns.farID;

trace("onPeerConnect "+farPeerID);

return true;
}

sendStream.client = sendStreamClient;

}
senders.addEventListener(MouseEvent.CLICK,sending);

function sending(eve:Event):void
{
trace("sending");
sendStream.send("receiveSomeData","sending");
}

function initRecvStream():void{

var customClient:Object = new Object();
customClient.onMetaData = metaDataHandler;

recvStream = new NetStream(nc,farPeerID);
recvStream.addEventListener(NetStatusEvent.NET_STATUS,netStatusHandler);


recvStream.client = {onMetaData:ns_onMetaData, onCuePoint:ns_onCuePoint};

recvStream.play(farPeerID);
video.attachNetStream(recvStream);

function metaDataHandler(infoObject:Object):void
{
trace(infoObject.width);
trace(infoObject.height);
}
}

function ns_onMetaData(item:Object):void {

trace("metaData");

video.width = item.width;
video.height = item.height;

video.x = (stage.stageWidth - video.width) / 2;
video.y = (stage.stageHeight - video.height) / 2;

}


function ns_onCuePoint(item:Object):void {
trace("cuePoint");
trace(item.name + "\t" + item.time);
}

function onMetaData(info:Object):void {
trace("width: " + info.width);
trace("height: " + info.height);
}

function receiveSomeData(str:String):void{

}

function sendSomeData():void{
//sendStream.send("receiveSomeData",txtSendData.text);
//txtSendData.text='';
}

function netStatusHandler(event:NetStatusEvent):void{
trace(event.info.code);

if (event.info.code == "NetConnection.Connect.Success") {


}

}
Цепь последовательности:
Сид получает от стратуса ИД записывает его в БД и начинает трансляцию.
Пир считывает БД подключается к Сид и начинает воспроизводить видеопоток.
Сид определивши подключение Пира создаёт для слушатель, который должен принимать и отдавать команды, свойства от/к Пира/у.

При моей реализации Сид сходит с ума, получая практически постоянно netStatusHandler2