From 9f33ce0ecd67afd8dd917d941f18b5af66e0e7fe Mon Sep 17 00:00:00 2001 From: Raja Subramanian Date: Fri, 17 Feb 2023 19:34:31 +0530 Subject: [PATCH] Declare migration complete after track publish callback. (#1436) --- pkg/rtc/participant.go | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/pkg/rtc/participant.go b/pkg/rtc/participant.go index c0587196b..2c54c055e 100644 --- a/pkg/rtc/participant.go +++ b/pkg/rtc/participant.go @@ -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 {