mirrors/gst-plugins-rs
mirrors/gst-plugins-rs
1
1
Fork 0
mirror of https://gitlab.freedesktop.org/gstreamer/gst-plugins-rs.git synced 2025-02-05 15:42:21 +00:00
Code Issues Projects Releases Wiki Activity

Allow changeing Congestion control algorithm at runtime

Browse source
This commit is contained in:
Thibault Saunier 2021-12-03 14:47:39 +00:00 committed by Mathieu Duponchelle
parent 80e3acda93
commit 5904e1ccb4
1 changed files with 22 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

24
plugins/src/webrtcsink/imp.rs
View file

@ -2023,7 +2023,7 @@ impl ObjectImpl for WebRTCSink {
"Defines how congestion is controlled, if at all", "Defines how congestion is controlled, if at all",
WebRTCSinkCongestionControl::static_type(), WebRTCSinkCongestionControl::static_type(),
DEFAULT_CONGESTION_CONTROL as i32, DEFAULT_CONGESTION_CONTROL as i32,
glib::ParamFlags::READWRITE | gst::PARAM_FLAG_MUTABLE_READY, glib::ParamFlags::READWRITE | gst::PARAM_FLAG_MUTABLE_PLAYING,
), ),
glib::ParamSpecUInt::new( glib::ParamSpecUInt::new(
"min-bitrate", "min-bitrate",
@ -2092,9 +2092,29 @@ impl ObjectImpl for WebRTCSink {
} }
"congestion-control" => { "congestion-control" => {
let mut settings = self.settings.lock().unwrap(); let mut settings = self.settings.lock().unwrap();
settings.cc_heuristic = value let new_heuristic = value
.get::<WebRTCSinkCongestionControl>() .get::<WebRTCSinkCongestionControl>()
.expect("type checked upstream"); .expect("type checked upstream");
if new_heuristic != settings.cc_heuristic {
settings.cc_heuristic = new_heuristic;
let mut state = self.state.lock().unwrap();
for (peer_id, consumer) in state.consumers.iter_mut() {
match new_heuristic {
WebRTCSinkCongestionControl::Disabled => {
consumer.congestion_controller.take();
},
WebRTCSinkCongestionControl::Homegrown => {
let _ = consumer.congestion_controller.insert(
CongestionController::new(
peer_id,
settings.min_bitrate,
settings.max_bitrate,
));
}
}
}
}
} }
"min-bitrate" => { "min-bitrate" => {
let mut settings = self.settings.lock().unwrap(); let mut settings = self.settings.lock().unwrap();