rafaelcaricio/gstreamer-rs
1
0
Fork 0
forked from mirrors/gstreamer-rs
Code Pull requests Activity

Implement Pad::sticky_events_foreach()

Browse source
This commit is contained in:
Sebastian Dröge 2018-08-13 19:58:30 +03:00
parent 999c84f0a0
commit 0d70950821
1 changed files with 49 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

49
gstreamer/src/pad.rs
View file

@ -226,6 +226,11 @@ pub trait PadExtManual {
fn query_position_generic(&self, format: Format) -> Option<GenericFormattedValue>;
fn get_mode(&self) -> ::PadMode;
fn sticky_events_foreach<F: FnMut(Event) -> Result<Option<Event>, Option<Event>>>(
&self,
func: F,
);
}
impl<O: IsA<Pad>> PadExtManual for O {
@ -868,6 +873,50 @@ impl<O: IsA<Pad>> PadExtManual for O {
from_glib(ptr.mode)
}
}
fn sticky_events_foreach<F: FnMut(Event) -> Result<Option<Event>, Option<Event>>>(
&self,
func: F,
) {
unsafe extern "C" fn trampoline(
_pad: *mut ffi::GstPad,
event: *mut *mut ffi::GstEvent,
user_data: glib_ffi::gpointer,
) -> glib_ffi::gboolean {
let func =
user_data as *mut &mut (FnMut(Event) -> Result<Option<Event>, Option<Event>>);
let res = (*func)(from_glib_full(*event));
match res {
Ok(Some(ev)) => {
*event = ev.into_ptr();
glib_ffi::GTRUE
}
Err(Some(ev)) => {
*event = ev.into_ptr();
glib_ffi::GFALSE
}
Ok(None) => {
*event = ptr::null_mut();
glib_ffi::GTRUE
}
Err(None) => {
*event = ptr::null_mut();
glib_ffi::GFALSE
}
}
}
unsafe {
let mut func = func;
let func_obj: &mut (FnMut(Event) -> Result<Option<Event>, Option<Event>>) = &mut func;
let func_ptr = &func_obj
as *const &mut (FnMut(Event) -> Result<Option<Event>, Option<Event>>)
as glib_ffi::gpointer;
ffi::gst_pad_sticky_events_foreach(self.to_glib_none().0, Some(trampoline), func_ptr);
}
}
}
unsafe extern "C" fn trampoline_pad_probe(