dandri/livekit
1
0
Fork 0
mirror of https://github.com/livekit/livekit.git synced 2026-08-28 11:44:43 +00:00
Code Issues Packages Projects Releases Wiki Activity

Check all transport connected for subscriber only properly. (#1661)

Browse Source
This commit is contained in:
Raja Subramanian
2023-04-27 23:06:15 +05:30
committed by GitHub
parent fc09cacfce
commit 3f3b02357c
2 changed files with 9 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files
pkg/rtc/participant.go
+5 -1
View File
@@ -735,7 +735,11 @@ func (p *ParticipantImpl) clearMigrationTimer() {
}
func (p *ParticipantImpl) MaybeStartMigration(force bool, onStart func()) bool {
if !force && !p.TransportManager.HaveAllTransportEverConnected() {
allTransportConnected := p.TransportManager.HasSubscriberEverConnected()
if p.IsPublisher() {
allTransportConnected = allTransportConnected && p.TransportManager.HasPublisherEverConnected()
}
if !force && !allTransportConnected {
return false
}
pkg/rtc/transportmanager.go
+4 -4
View File
@@ -190,10 +190,6 @@ func (t *TransportManager) Close() {
t.subscriber.Close()
}
func (t *TransportManager) HaveAllTransportEverConnected() bool {
return t.publisher.HasEverConnected() && t.subscriber.HasEverConnected()
}
func (t *TransportManager) SubscriberClose() {
t.subscriber.Close()
}
@@ -217,6 +213,10 @@ func (t *TransportManager) OnPublisherTrack(f func(track *webrtc.TrackRemote, rt
t.publisher.OnTrack(f)
}
func (t *TransportManager) HasPublisherEverConnected() bool {
return t.publisher.HasEverConnected()
}
func (t *TransportManager) IsPublisherEstablished() bool {
return t.publisher.IsEstablished()
}