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-12-23 02:26:35 +00:00
Code Issues Projects Releases Wiki Activity

fallbacksrc: Don't panic when shutting down the source and there are source pad blocks but no actual source pads

Browse source 
This can happen if the source removed the actual source pad already but
our downstream pad that is blocked still exists.
This commit is contained in:
Sebastian Dröge 2022-04-11 13:36:48 +03:00 committed by Sebastian Dröge
parent 84402f39ef
commit 3de317b3c9
1 changed files with 12 additions and 11 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

23
utils/fallbackswitch/src/fallbacksrc/imp.rs
View file

@ -2094,22 +2094,23 @@ impl FallbackSrc {
}
Some(state) => state,
};
for (source_srcpad, block) in [state.video_stream.as_mut(), state.audio_stream.as_mut()]
.iter_mut()
.filter_map(|s| s.as_mut())
.filter_map(|s| {
if let Some(block) = s.source_srcpad_block.take() {
Some((s.source_srcpad.as_ref().unwrap(), block))
} else {
None
}
})
for (source_srcpad_name, block) in
[state.video_stream.as_mut(), state.audio_stream.as_mut()]
.iter_mut()
.filter_map(|s| s.as_mut())
.filter_map(|s| {
if let Some(block) = s.source_srcpad_block.take() {
Some((s.source_srcpad.as_ref().map(|pad| pad.name()), block))
} else {
None
}
})
{
gst::debug!(
CAT,
obj: element,
"Removing pad probe for pad {}",
source_srcpad.name()
source_srcpad_name.as_deref().unwrap_or("UNKNOWN")
);
block.pad.remove_probe(block.probe_id);
}