mirrors/gstreamer-rs
mirrors/gstreamer-rs
1
1
Fork 1
mirror of https://gitlab.freedesktop.org/gstreamer/gstreamer-rs.git synced 2024-06-14 20:29:25 +00:00
Code Issues Projects Releases Wiki Activity

gstreamer/pad: Factor out PadProbeInfo handling from pad probe trampoline into separate functions

Browse source 
This makes that part of the code non-generic and thus allows the
compiler to not put a copy of it into every caller with a different
closure.

For a test with 3 pad probes this overall reduced the number of LLVM IR
lines needed for the pad probes to about 8.5% of what it was before
(4485 -> 381 lines).
This commit is contained in:
Sebastian Dröge 2020-08-05 10:30:05 +03:00
parent 9ffe2238a7
commit 43d1d0a4e9
1 changed files with 34 additions and 18 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

52
gstreamer/src/pad.rs
View file

@ -1070,21 +1070,11 @@ impl<O: IsA<Pad>> PadExtManual for O {
}
}
unsafe extern "C" fn trampoline_pad_probe<
T,
F: Fn(&T, &mut PadProbeInfo) -> PadProbeReturn + Send + Sync + 'static,
>(
pad: *mut gst_sys::GstPad,
unsafe fn create_probe_info<'a>(
info: *mut gst_sys::GstPadProbeInfo,
func: gpointer,
) -> gst_sys::GstPadProbeReturn
where
T: IsA<Pad>,
{
let func: &F = &*(func as *const F);
) -> (PadProbeInfo<'a>, Option<glib::Type>) {
let mut data_type = None;
let mut probe_info = PadProbeInfo {
let info = PadProbeInfo {
mask: from_glib((*info).type_),
id: PadProbeId(NonZeroU64::new_unchecked((*info).id as u64)),
offset: (*info).offset,
@ -1120,12 +1110,15 @@ where
},
flow_ret: from_glib((*info).ABI.abi.flow_ret),
};
(info, data_type)
}
let ret = func(
&Pad::from_glib_borrow(pad).unsafe_cast_ref(),
&mut probe_info,
);
unsafe fn update_probe_info(
ret: PadProbeReturn,
probe_info: PadProbeInfo,
data_type: Option<glib::Type>,
info: *mut gst_sys::GstPadProbeInfo,
) {
if ret == PadProbeReturn::Handled {
// Handled queries need to be returned
// Handled buffers are consumed
@ -1177,6 +1170,29 @@ where
}
(*info).ABI.abi.flow_ret = probe_info.flow_ret.to_glib();
}
unsafe extern "C" fn trampoline_pad_probe<
T,
F: Fn(&T, &mut PadProbeInfo) -> PadProbeReturn + Send + Sync + 'static,
>(
pad: *mut gst_sys::GstPad,
info: *mut gst_sys::GstPadProbeInfo,
func: gpointer,
) -> gst_sys::GstPadProbeReturn
where
T: IsA<Pad>,
{
let func: &F = &*(func as *const F);
let (mut probe_info, data_type) = create_probe_info(info);
let ret = func(
&Pad::from_glib_borrow(pad).unsafe_cast_ref(),
&mut probe_info,
);
update_probe_info(ret, probe_info, data_type, info);
ret.to_glib()
}