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

Add support for queries in pad probes

Browse source
This commit is contained in:
Sebastian Dröge 2017-07-29 16:09:14 +01:00
parent 0c3c4166e4
commit 2915bfa299
1 changed files with 11 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

15
gstreamer/src/pad.rs
View file

@ -12,6 +12,7 @@ use PadProbeReturn;
use Buffer; use Buffer;
use BufferList; use BufferList;
use FlowReturn; use FlowReturn;
use Query;
use QueryRef; use QueryRef;
use miniobject::MiniObject; use miniobject::MiniObject;
@ -47,18 +48,18 @@ impl FromGlib<libc::c_ulong> for PadProbeId {
} }
} }
pub struct PadProbeInfo { pub struct PadProbeInfo<'a> {
pub mask: PadProbeType, pub mask: PadProbeType,
pub id: PadProbeId, pub id: PadProbeId,
pub offset: u64, pub offset: u64,
pub size: u32, pub size: u32,
pub data: Option<PadProbeData>, pub data: Option<PadProbeData<'a>>,
} }
pub enum PadProbeData { pub enum PadProbeData<'a> {
Buffer(Buffer), Buffer(Buffer),
BufferList(BufferList), BufferList(BufferList),
// Query(&Query), Query(&'a mut QueryRef),
// Event(&Event), // Event(&Event),
Unknown, Unknown,
} }
@ -211,6 +212,11 @@ unsafe extern "C" fn trampoline_pad_probe(
Some(PadProbeData::BufferList( Some(PadProbeData::BufferList(
from_glib_none(data as *const ffi::GstBufferList), from_glib_none(data as *const ffi::GstBufferList),
)) ))
} else if (*data).type_ == Query::static_type().to_glib() {
data_type = Some(Query::static_type());
Some(PadProbeData::Query(
QueryRef::from_mut_ptr(data as *mut ffi::GstQuery),
))
} else { } else {
Some(PadProbeData::Unknown) Some(PadProbeData::Unknown)
} }
@ -235,6 +241,7 @@ unsafe extern "C" fn trampoline_pad_probe(
} }
} }
None => { None => {
assert_ne!(data_type, Some(Query::static_type()));
if !(*info).data.is_null() { if !(*info).data.is_null() {
ffi::gst_mini_object_unref((*info).data as *mut _); ffi::gst_mini_object_unref((*info).data as *mut _);
(*info).data = ptr::null_mut(); (*info).data = ptr::null_mut();