mirror of
https://gitlab.freedesktop.org/gstreamer/gstreamer-rs.git
synced 2024-11-25 11:01:10 +00:00
rtp: Add support for new RTPBasePayload::extensions
property
Part-of: <https://gitlab.freedesktop.org/gstreamer/gstreamer-rs/-/merge_requests/1368>
This commit is contained in:
parent
dff595193d
commit
0533160d94
2 changed files with 48 additions and 1 deletions
|
@ -97,6 +97,11 @@ manual_traits = ["RTPHeaderExtensionExtManual"]
|
|||
manual = true
|
||||
rename = "set_outcaps"
|
||||
|
||||
[[object.property]]
|
||||
name = "extensions"
|
||||
# use proper type
|
||||
ignore = true
|
||||
|
||||
[[object]]
|
||||
name = "GstRtp.RTPBuffer"
|
||||
status = "manual"
|
||||
|
|
|
@ -1,6 +1,6 @@
|
|||
use std::ptr;
|
||||
|
||||
use glib::{object::IsA, translate::*};
|
||||
use glib::{prelude::*, translate::*};
|
||||
|
||||
use crate::RTPBasePayload;
|
||||
|
||||
|
@ -28,6 +28,48 @@ pub trait RTPBasePayloadExtManual: sealed::Sealed + IsA<RTPBasePayload> + 'stati
|
|||
}
|
||||
}
|
||||
|
||||
#[cfg(feature = "v1_24")]
|
||||
#[cfg_attr(docsrs, doc(cfg(feature = "v1_24")))]
|
||||
fn extensions(&self) -> Vec<crate::RTPHeaderExtension> {
|
||||
let extensions = self.as_ref().property::<gst::Array>("extensions");
|
||||
|
||||
extensions
|
||||
.iter()
|
||||
.map(|v| v.get::<crate::RTPHeaderExtension>().unwrap())
|
||||
.collect()
|
||||
}
|
||||
|
||||
#[cfg(feature = "v1_24")]
|
||||
#[cfg_attr(docsrs, doc(cfg(feature = "v1_24")))]
|
||||
#[doc(alias = "extensions")]
|
||||
fn connect_extensions_notify<F: Fn(&Self) + Send + Sync + 'static>(
|
||||
&self,
|
||||
f: F,
|
||||
) -> glib::SignalHandlerId {
|
||||
unsafe extern "C" fn notify_extensions_trampoline<
|
||||
P: IsA<RTPBasePayload>,
|
||||
F: Fn(&P) + Send + Sync + 'static,
|
||||
>(
|
||||
this: *mut ffi::GstRTPBasePayload,
|
||||
_param_spec: glib::ffi::gpointer,
|
||||
f: glib::ffi::gpointer,
|
||||
) {
|
||||
let f: &F = &*(f as *const F);
|
||||
f(RTPBasePayload::from_glib_borrow(this).unsafe_cast_ref())
|
||||
}
|
||||
unsafe {
|
||||
let f: Box<F> = Box::new(f);
|
||||
glib::signal::connect_raw(
|
||||
self.as_ptr() as *mut _,
|
||||
b"notify::extensions\0".as_ptr() as *const _,
|
||||
Some(std::mem::transmute::<_, unsafe extern "C" fn()>(
|
||||
notify_extensions_trampoline::<Self, F> as *const (),
|
||||
)),
|
||||
Box::into_raw(f),
|
||||
)
|
||||
}
|
||||
}
|
||||
|
||||
fn sink_pad(&self) -> &gst::Pad {
|
||||
unsafe {
|
||||
let elt = &*(self.as_ptr() as *const ffi::GstRTPBasePayload);
|
||||
|
|
Loading…
Reference in a new issue