Rosetta/g365sfu
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Исправление форвардинга RTP

Browse Source
This commit is contained in:
set
2026-03-16 19:25:28 +02:00
parent 3fb5f83f38
commit 380299295d
1 changed files with 10 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

13
sfu/forwarding.go
View File

@@ -92,6 +92,13 @@ func BindPeerLifecycle(roomID, peerID string, pc *webrtc.PeerConnection) {
timer *time.Timer timer *time.Timer
) )
room, exists := GetRoom(roomID)
if !exists {
logger.LogWarnMessage("BindPeerLifecycle: tried to bind non existing room " + roomID)
return
}
server := room.Server
startTimer := func() { startTimer := func() {
mu.Lock() mu.Lock()
defer mu.Unlock() defer mu.Unlock()
@@ -109,7 +116,7 @@ func BindPeerLifecycle(roomID, peerID string, pc *webrtc.PeerConnection) {
} }
_ = LeaveRoom(roomID, peerID) _ = LeaveRoom(roomID, peerID)
if OnPeerDisconnected != nil { if OnPeerDisconnected != nil {
OnPeerDisconnected(roomID, peerID) OnPeerDisconnected(roomID, peerID, server)
} }
}) })
} }
@@ -134,7 +141,7 @@ func BindPeerLifecycle(roomID, peerID string, pc *webrtc.PeerConnection) {
cancelTimer() cancelTimer()
_ = LeaveRoom(roomID, peerID) _ = LeaveRoom(roomID, peerID)
if OnPeerDisconnected != nil { if OnPeerDisconnected != nil {
OnPeerDisconnected(roomID, peerID) OnPeerDisconnected(roomID, peerID, server)
} }
} }
}) })
@@ -149,7 +156,7 @@ func BindPeerLifecycle(roomID, peerID string, pc *webrtc.PeerConnection) {
cancelTimer() cancelTimer()
_ = LeaveRoom(roomID, peerID) _ = LeaveRoom(roomID, peerID)
if OnPeerDisconnected != nil { if OnPeerDisconnected != nil {
OnPeerDisconnected(roomID, peerID) OnPeerDisconnected(roomID, peerID, server)
} }
} }
}) })