From 5cdea4e15d0695ca43a501f75f89d9c482b5b40a Mon Sep 17 00:00:00 2001 From: Artur Shellunts Date: Wed, 12 Jan 2022 10:23:55 +0100 Subject: [PATCH] Avoid per packet operation (#332) --- pkg/rtc/mediatracksubscriptions.go | 7 ++++--- 1 file changed, 4 insertions(+), 3 deletions(-) diff --git a/pkg/rtc/mediatracksubscriptions.go b/pkg/rtc/mediatracksubscriptions.go index 40e2cfacd..2042ca2f0 100644 --- a/pkg/rtc/mediatracksubscriptions.go +++ b/pkg/rtc/mediatracksubscriptions.go @@ -176,14 +176,15 @@ func (t *MediaTrackSubscriptions) AddSubscriber(sub types.LocalParticipant, code go subTrack.Bound() go t.sendDownTrackBindingReports(sub) }) + trackID := t.params.MediaTrack.ID() downTrack.OnPacketSent(func(_ *sfu.DownTrack, size int) { - t.params.Telemetry.OnDownstreamPacket(subscriberID, t.params.MediaTrack.ID(), size) + t.params.Telemetry.OnDownstreamPacket(subscriberID, trackID, size) }) downTrack.OnPaddingSent(func(_ *sfu.DownTrack, size int) { - t.params.Telemetry.OnDownstreamPacket(subscriberID, t.params.MediaTrack.ID(), size) + t.params.Telemetry.OnDownstreamPacket(subscriberID, trackID, size) }) downTrack.OnRTCP(func(pkts []rtcp.Packet) { - t.params.Telemetry.HandleRTCP(livekit.StreamType_DOWNSTREAM, subscriberID, t.params.MediaTrack.ID(), pkts) + t.params.Telemetry.HandleRTCP(livekit.StreamType_DOWNSTREAM, subscriberID, trackID, pkts) }) downTrack.OnCloseHandler(func() {