Don't add duplicates in addLocal.
This commit is contained in:
1 parent
9575b80893
commit
2a35f4e5d9
1 file changed
+6
@@ -52,6 +52,12 @@ func (up *upTrack) notifyLocal() {
|
|||||||
|
|
||||||
func (up *upTrack) addLocal(local *downTrack) {
|
func (up *upTrack) addLocal(local *downTrack) {
|
||||||
up.mu.Lock()
|
up.mu.Lock()
|
||||||
|
for _, t := range up.local {
|
||||||
|
if t == local {
|
||||||
|
up.mu.Unlock()
|
||||||
|
return
|
||||||
|
}
|
||||||
|
}
|
||||||
up.local = append(up.local, local)
|
up.local = append(up.local, local)
|
||||||
up.mu.Unlock()
|
up.mu.Unlock()
|
||||||
up.notifyLocal()
|
up.notifyLocal()
|
||||||
|
|||||||
Reference in new issue
Block a user