yumoqing/bricks
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

bugfix

Browse Source
This commit is contained in:
yumoqing 2024-10-16 23:09:54 +08:00
parent d923b973d2
commit 517cd150d8
1 changed files with 5 additions and 15 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

20
bricks/rtc.js
View File

@ -61,12 +61,10 @@ bricks.Signaling = class {
this.onclose(); this.onclose();
} }
return; return;
try { }
this.socket.close(); del_handler(sessionid){
} catch(e){ var handlers = {};
console.log('error,', e); delete self.handlers[sessionid];
}
this.init_websocket();
} }
async signaling_recvdata(event){ async signaling_recvdata(event){
var datapkg = JSON.parse(event.data); var datapkg = JSON.parse(event.data);
@ -110,15 +108,6 @@ bricks.Signaling = class {
} }
return; return;
} }
if (data.type == 'new_session'){
var peers = {};
Object.keys(this.peers).forEach(k =>{
if (k != data.msgfrom.id){
peers[k] = this.peers[k];
}
});
return;
}
console.log('recv data=', data, 'NOT HANDLED'); console.log('recv data=', data, 'NOT HANDLED');
} }
new_session(sessiontype, peer){ new_session(sessiontype, peer){
@ -467,6 +456,7 @@ bricks.RTCP2PConnect = class {
.getTracks().forEach(track => track.stop()); .getTracks().forEach(track => track.stop());
this.local_stream.getTracks().forEach(track => track.stop()); this.local_stream.getTracks().forEach(track => track.stop());
this.local_screan.getTracks().forEach(track => track.stop()); this.local_screan.getTracks().forEach(track => track.stop());
this.signaling.del_handler(this.session.sessionid);
} }
} }
}; };