From f5e2c1da15cd971ee0818fb8fe7635600cb699fb Mon Sep 17 00:00:00 2001 From: Raja Subramanian Date: Sun, 24 Dec 2023 14:03:51 +0530 Subject: [PATCH] Debug log downtrack life cycle a bit (#2342) --- pkg/sfu/downtrack.go | 1 + pkg/sfu/receiver.go | 2 ++ 2 files changed, 3 insertions(+) diff --git a/pkg/sfu/downtrack.go b/pkg/sfu/downtrack.go index 4a0533a73..57da4a30f 100644 --- a/pkg/sfu/downtrack.go +++ b/pkg/sfu/downtrack.go @@ -1579,6 +1579,7 @@ func (d *DownTrack) SetConnected() { if !d.connected.Swap(true) { d.onBindAndConnectedChange() } + d.params.Logger.Debugw("downtrack connected") } // SetActivePaddingOnMuteUpTrack will enable padding on the track when its uptrack is muted. diff --git a/pkg/sfu/receiver.go b/pkg/sfu/receiver.go index e555b99f9..ae368b42f 100644 --- a/pkg/sfu/receiver.go +++ b/pkg/sfu/receiver.go @@ -421,6 +421,7 @@ func (w *WebRTCReceiver) AddDownTrack(track TrackSender) error { track.UpTrackMaxTemporalLayerSeenChange(w.streamTrackerManager.GetMaxTemporalLayerSeen()) w.downTrackSpreader.Store(track) + w.logger.Debugw("downtrack added", "subscriberID", track.SubscriberID()) return nil } @@ -505,6 +506,7 @@ func (w *WebRTCReceiver) DeleteDownTrack(subscriberID livekit.ParticipantID) { } w.downTrackSpreader.Free(subscriberID) + w.logger.Debugw("downtrack deleted", "subscriberID", subscriberID) } func (w *WebRTCReceiver) sendRTCP(packets []rtcp.Packet) {