Mirrors/cloud-game
1
0
Fork 0
mirror of https://github.com/giongto35/cloud-game.git synced 2026-07-23 01:57:22 +00:00
Code Issues Projects Releases Packages Wiki Activity

add recover for inputchannel

Browse source
This commit is contained in:
giongto35 2019-05-10 01:51:39 +08:00
parent c9de9471c9
commit bc97bc1e53
1 changed files with 6 additions and 4 deletions
Download patch file Download diff file Expand all files Collapse all files

10
handler/room/room.go
View file

@ -108,6 +108,12 @@ func (r *Room) AddConnectionToRoom(peerconnection *webrtc.WebRTC, playerIndex in
}
func (r *Room) startWebRTCSession(peerconnection *webrtc.WebRTC, playerIndex int) {
defer func() {
if r := recover(); r != nil {
fmt.Println("Recovered when sent to close inputChannel")
}
}()
for {
select {
case <-r.Done:
@ -140,10 +146,6 @@ func (r *Room) startWebRTCSession(peerconnection *webrtc.WebRTC, playerIndex int
func (r *Room) CleanSession(peerconnection *webrtc.WebRTC) {
r.removeSession(peerconnection)
// TODO: Clean all channels
//close(peerconnection.ImageChannel)
//close(peerconnection.AudioChannel)
//close(peerconnection.InputChannel)
}
func (r *Room) removeSession(w *webrtc.WebRTC) {