Send up actions synchronously.
This commit is contained in:
+2
-5
@@ -366,15 +366,12 @@ func (up *rtpUpTrack) AddLocal(local conn.DownTrack) error {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
up.local = append(up.local, local)
|
up.local = append(up.local, local)
|
||||||
|
up.action(trackActionAdd, local)
|
||||||
// do this asynchronously, to avoid deadlocks when multiple
|
|
||||||
// clients call this simultaneously.
|
|
||||||
go up.action(trackActionAdd, local)
|
|
||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
|
|
||||||
func (up *rtpUpTrack) RequestKeyframe() error {
|
func (up *rtpUpTrack) RequestKeyframe() error {
|
||||||
go up.action(trackActionKeyframe, nil)
|
up.action(trackActionKeyframe, nil)
|
||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user