forked from mirrors/gstreamer-rs
105 lines
2.7 KiB
Rust
105 lines
2.7 KiB
Rust
// Take a look at the license at the top of the repository in the LICENSE file.
|
|
|
|
use std::fmt;
|
|
use std::ptr;
|
|
|
|
use glib::translate::*;
|
|
use gst::prelude::*;
|
|
|
|
#[repr(transparent)]
|
|
#[doc(alias = "GstRTPSourceMeta")]
|
|
pub struct RTPSourceMeta(ffi::GstRTPSourceMeta);
|
|
|
|
unsafe impl Send for RTPSourceMeta {}
|
|
unsafe impl Sync for RTPSourceMeta {}
|
|
|
|
impl RTPSourceMeta {
|
|
#[doc(alias = "gst_buffer_add_rtp_source_meta")]
|
|
pub fn add<'a>(
|
|
buffer: &'a mut gst::BufferRef,
|
|
ssrc: Option<u32>,
|
|
csrc: &[u32],
|
|
) -> gst::MetaRefMut<'a, Self, gst::meta::Standalone> {
|
|
skip_assert_initialized!();
|
|
unsafe {
|
|
let meta = ffi::gst_buffer_add_rtp_source_meta(
|
|
buffer.as_mut_ptr(),
|
|
ssrc.as_ref()
|
|
.map(|ssrc: &u32| ssrc as *const u32)
|
|
.unwrap_or(ptr::null()),
|
|
csrc.as_ptr(),
|
|
csrc.len() as u32,
|
|
);
|
|
|
|
Self::from_mut_ptr(buffer, meta)
|
|
}
|
|
}
|
|
|
|
#[inline]
|
|
pub fn ssrc(&self) -> Option<u32> {
|
|
unsafe {
|
|
if from_glib(self.0.ssrc_valid) {
|
|
Some(self.0.ssrc)
|
|
} else {
|
|
None
|
|
}
|
|
}
|
|
}
|
|
|
|
#[inline]
|
|
pub fn csrc(&self) -> &[u32] {
|
|
&self.0.csrc[0..self.0.csrc_count as usize]
|
|
}
|
|
|
|
#[doc(alias = "gst_rtp_source_meta_set_ssrc")]
|
|
#[inline]
|
|
pub fn set_ssrc(&mut self, ssrc: Option<u32>) {
|
|
unsafe {
|
|
ffi::gst_rtp_source_meta_set_ssrc(
|
|
&mut self.0,
|
|
mut_override(
|
|
ssrc.as_ref()
|
|
.map(|ssrc: &u32| ssrc as *const u32)
|
|
.unwrap_or(ptr::null()),
|
|
),
|
|
);
|
|
}
|
|
}
|
|
|
|
#[inline]
|
|
#[doc(alias = "gst_rtp_source_meta_append_csrc")]
|
|
pub fn append_csrc(&mut self, csrc: &[u32]) -> Result<(), glib::BoolError> {
|
|
unsafe {
|
|
let res: bool = from_glib(ffi::gst_rtp_source_meta_append_csrc(
|
|
&mut self.0,
|
|
csrc.as_ptr(),
|
|
csrc.len() as u32,
|
|
));
|
|
|
|
if res {
|
|
Ok(())
|
|
} else {
|
|
Err(glib::bool_error!("Failed adding another CSRC"))
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
unsafe impl MetaAPI for RTPSourceMeta {
|
|
type GstType = ffi::GstRTPSourceMeta;
|
|
|
|
#[doc(alias = "gst_rtp_source_meta_api_get_type")]
|
|
#[inline]
|
|
fn meta_api() -> glib::Type {
|
|
unsafe { from_glib(ffi::gst_rtp_source_meta_api_get_type()) }
|
|
}
|
|
}
|
|
|
|
impl fmt::Debug for RTPSourceMeta {
|
|
fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
|
|
f.debug_struct("RTPSourceMeta")
|
|
.field("ssrc", &self.ssrc())
|
|
.field("csrc", &self.csrc())
|
|
.finish()
|
|
}
|
|
}
|