dandri/livekit
1
0
Fork 0
mirror of https://github.com/livekit/livekit.git synced 2026-08-24 20:29:44 +00:00
Code Issues Packages Projects Releases Wiki Activity

Move lock to addPendingTrack function. (#4617)

Browse Source 
Wrapping the function with the lock outside in the only invocation was
not needed.
This commit is contained in:
Raja Subramanian
2026-06-23 10:30:59 +05:30
committed by GitHub
parent 1b69630a28
commit 4facbc582a
1 changed files with 5 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files
pkg/rtc/participant.go
+5 -4
View File
@@ -1340,9 +1340,7 @@ func (p *ParticipantImpl) AddTrack(req *livekit.AddTrackRequest) {
return
}
p.pendingTracksLock.Lock()
ti := p.addPendingTrackLocked(req)
p.pendingTracksLock.Unlock()
ti := p.addPendingTrack(req)
if ti == nil {
return
}
@@ -2852,7 +2850,10 @@ func (p *ParticipantImpl) onSubscribedAudioCodecChange(
return p.sendSubscribedAudioCodecUpdate(subscribedAudioCodecUpdate)
}
func (p *ParticipantImpl) addPendingTrackLocked(req *livekit.AddTrackRequest) *livekit.TrackInfo {
func (p *ParticipantImpl) addPendingTrack(req *livekit.AddTrackRequest) *livekit.TrackInfo {
p.pendingTracksLock.Lock()
defer p.pendingTracksLock.Unlock()
if req.Sid != "" {
track := p.GetPublishedTrack(livekit.TrackID(req.Sid))
if track == nil {