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-01 16:01:01 +00:00
Code Issues Projects Releases Wiki Activity

Merge pull request #98 from ubifred/master

Browse source 
Error out on EOS event if no src pad exist
This commit is contained in:
Samuel Alonso Rodriguez 2022-04-09 11:59:53 +02:00 committed by GitHub
commit 12656afe7d
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
1 changed files with 29 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

29
src/ndisrcdemux/imp.rs
View file

@ -48,6 +48,13 @@ impl ObjectSubclass for NdiSrcDemux {
|self_, element| self_.sink_chain(pad, element, buffer),
)
})
.event_function(|pad, parent, event| {
NdiSrcDemux::catch_panic_pad_function(
parent,
|| false,
|self_, element| self_.sink_event(pad, element, event),
)
})
.build();
Self {
@ -280,4 +287,26 @@ impl NdiSrcDemux {
let mut state = self.state.lock().unwrap();
state.combiner.update_pad_flow(&srcpad, res)
}
fn sink_event(&self,
pad: &gst::Pad,
element: &super::NdiSrcDemux,
event: gst::Event
) -> bool {
use gst::EventView;
gst_log!(CAT, obj: pad, "Handling event {:?}", event);
if let EventView::Eos(_) = event.view() {
if element.num_src_pads() == 0 {
// error out on EOS if no src pad are available
gst::element_error!(
element,
gst::StreamError::Demux,
["EOS without available srcpad(s)"]
);
}
}
pad.event_default(Some(element), event)
}
}