diff --git a/pkg/rtc/mediatrackreceiver.go b/pkg/rtc/mediatrackreceiver.go index 6d9d8dc65..04dd55af6 100644 --- a/pkg/rtc/mediatrackreceiver.go +++ b/pkg/rtc/mediatrackreceiver.go @@ -280,7 +280,7 @@ func (t *MediaTrackReceiver) Close() { onclose := t.onClose t.lock.RUnlock() - t.MediaTrackSubscriptions.Stop() + t.MediaTrackSubscriptions.Close() for _, f := range onclose { f() } diff --git a/pkg/rtc/mediatracksubscriptions.go b/pkg/rtc/mediatracksubscriptions.go index 5ee5432cc..6d714072a 100644 --- a/pkg/rtc/mediatracksubscriptions.go +++ b/pkg/rtc/mediatracksubscriptions.go @@ -93,6 +93,10 @@ func (t *MediaTrackSubscriptions) Restart() { } func (t *MediaTrackSubscriptions) Stop() { + t.stopMaxQualityTimer() +} + +func (t *MediaTrackSubscriptions) Close() { t.qualityNotifyOpQueue.Stop() t.stopMaxQualityTimer() } diff --git a/pkg/rtc/participant.go b/pkg/rtc/participant.go index d2f4d50ae..38c6765e8 100644 --- a/pkg/rtc/participant.go +++ b/pkg/rtc/participant.go @@ -1674,7 +1674,7 @@ func (p *ParticipantImpl) mediaTrackReceived(track *webrtc.TrackRemote, rtpRecei p.pendingTracksLock.Lock() newTrack := false - p.params.Logger.Debugw("media track received", "track", track.ID(), "kind", track.Kind()) + p.params.Logger.Debugw("media track received", "trackID", track.ID(), "kind", track.Kind()) var mid string for _, tr := range p.publisher.pc.GetTransceivers() { if tr.Receiver() == rtpReceiver {