dandri/livekit
1
0
Fork 0
mirror of https://github.com/livekit/livekit.git synced 2026-05-10 19:17:07 +00:00
Code Issues Packages Projects Releases Wiki Activity

Avoid per packet operation (#332)

Browse Source
This commit is contained in:
Artur Shellunts
2022-01-12 10:23:55 +01:00
committed by GitHub
parent b05d154d12
commit 5cdea4e15d
1 changed files with 4 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files
pkg/rtc/mediatracksubscriptions.go
+4 -3
View File
@@ -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() {