dandri/livekit
1
0
Fork 0
mirror of https://github.com/livekit/livekit.git synced 2026-05-25 12:04:47 +00:00
Code Issues Packages Projects Releases Wiki Activity

Declare migration complete after track publish callback. (#1436)

Browse Source
This commit is contained in:
Raja Subramanian
2023-02-17 19:34:31 +05:30
committed by GitHub
parent 85a23bfffc
commit 9f33ce0ecd
1 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files
pkg/rtc/participant.go
+4 -4
View File
@@ -1691,10 +1691,6 @@ func (p *ParticipantImpl) addMediaTrack(signalCid string, sdpCid string, ti *liv
}
func (p *ParticipantImpl) handleTrackPublished(track types.MediaTrack) {
if !p.hasPendingMigratedTrack() {
p.SetMigrateState(types.MigrateStateComplete)
}
p.lock.RLock()
onTrackPublished := p.onTrackPublished
p.lock.RUnlock()
@@ -1710,6 +1706,10 @@ func (p *ParticipantImpl) handleTrackPublished(track types.MediaTrack) {
p.Identity(),
track.ToProto(),
)
if !p.hasPendingMigratedTrack() {
p.SetMigrateState(types.MigrateStateComplete)
}
}
func (p *ParticipantImpl) hasPendingMigratedTrack() bool {