mirrors/gst-plugins-rs
mirrors/gst-plugins-rs
1
1
Fork 0
mirror of https://gitlab.freedesktop.org/gstreamer/gst-plugins-rs.git synced 2024-11-26 13:31:00 +00:00
Code Issues Projects Releases Wiki Activity

transcriberbin: make sure to always record pad property changes

Browse source 
When the pad isn't parented yet we should still record user choices,
either in our settings or in our state.

Part-of: <https://gitlab.freedesktop.org/gstreamer/gst-plugins-rs/-/merge_requests/1593>
This commit is contained in:
Mathieu Duponchelle 2024-06-05 17:23:34 +02:00 committed by GStreamer Marge Bot
parent 0e85973e94
commit 7cec628c43
1 changed files with 22 additions and 19 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

31
video/closedcaption/src/transcriberbin/imp.rs
View file

@ -300,7 +300,8 @@ impl TranscriberBin {
channel.link_transcriber(&pad_state.transcriber)?;
let srcpad =
gst::GhostPad::builder_with_target(&channel.bin.static_pad("src").unwrap()).unwrap()
gst::GhostPad::builder_with_target(&channel.bin.static_pad("src").unwrap())
.unwrap()
.name(format!("src_{}", channel.language))
.build();
@ -1898,35 +1899,37 @@ impl ObjectImpl for TranscriberSinkPad {
}
}
"language-code" => {
if let Some(this) = self.obj().parent().and_downcast::<super::TranscriberBin>() {
let code = value
let mut settings = self.settings.lock().unwrap();
let old_code = settings.language_code.clone();
let new_code = value
.get::<Option<String>>()
.expect("type checked upstream")
.unwrap_or_else(|| String::from(DEFAULT_INPUT_LANG_CODE));
let mut settings = self.settings.lock().unwrap();
if settings.language_code != code {
settings.language_code.clone_from(&new_code);
if let Some(this) = self.obj().parent().and_downcast::<super::TranscriberBin>() {
drop(settings);
if new_code != old_code {
gst::debug!(
CAT,
imp: self,
"Updating language code {} -> {code}",
settings.language_code,
"Updating language code {old_code} -> {new_code}",
);
settings.language_code = code;
drop(settings);
this.imp().update_languages(&self.obj(), true)
}
}
}
"transcriber" => {
if let Some(this) = self.obj().parent().and_downcast::<super::TranscriberBin>() {
let mut s = this.imp().state.lock().unwrap();
let mut ps = self.state.lock().unwrap();
let pad_state = ps.as_mut().unwrap();
let old_transcriber = pad_state.transcriber.clone();
pad_state.transcriber = value.get().expect("type checked upstream");
if old_transcriber != pad_state.transcriber {
let new_transcriber: gst::Element = value.get().expect("type checked upstream");
pad_state.transcriber = new_transcriber.clone();
if let Some(this) = self.obj().parent().and_downcast::<super::TranscriberBin>() {
let mut s = this.imp().state.lock().unwrap();
if old_transcriber != new_transcriber {
if let Some(ref mut state) = s.as_mut() {
match this
.imp()