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

Use SubscriberID() is calls to DeleteDownTrack. (#2533)

Browse Source 
Thank you @cnderrauber for catching this.
This commit is contained in:
Raja Subramanian
2024-03-01 15:21:00 +05:30
committed by GitHub
parent 9e334c7510
commit 6a0b72c357
2 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files
pkg/rtc/wrappedreceiver.go
+3 -3
View File
@@ -263,13 +263,13 @@ func (d *DummyReceiver) AddDownTrack(track sfu.TrackSender) error {
return nil
}
func (d *DummyReceiver) DeleteDownTrack(participantID livekit.ParticipantID) {
func (d *DummyReceiver) DeleteDownTrack(subscriberID livekit.ParticipantID) {
d.downtrackLock.Lock()
defer d.downtrackLock.Unlock()
if r, ok := d.receiver.Load().(sfu.TrackReceiver); ok {
r.DeleteDownTrack(participantID)
r.DeleteDownTrack(subscriberID)
} else {
delete(d.downtracks, participantID)
delete(d.downtracks, subscriberID)
}
}
pkg/sfu/downtrack.go
+1 -1
View File
@@ -981,7 +981,7 @@ func (d *DownTrack) CloseWithFlush(flush bool) {
d.onBindAndConnectedChange()
d.params.Logger.Debugw("closing sender", "kind", d.kind)
}
d.params.Receiver.DeleteDownTrack(d.params.SubID)
d.params.Receiver.DeleteDownTrack(d.SubscriberID())
if d.rtcpReader != nil && flush {
d.params.Logger.Debugw("downtrack close rtcp reader")