rtp: Add RTPSourceMeta bindings

Part-of: <https://gitlab.freedesktop.org/gstreamer/gstreamer-rs/-/merge_requests/1376>

gstreamer-rtp/src/lib.rs

@@ -42,6 +42,13 @@ pub mod rtp_base_payload;
 
 pub mod rtp_base_depayload;
 
+#[cfg(feature = "v1_16")]
+#[cfg_attr(docsrs, doc(cfg(feature = "v1_16")))]
+mod rtp_meta;
+#[cfg(feature = "v1_16")]
+#[cfg_attr(docsrs, doc(cfg(feature = "v1_16")))]
+pub use crate::rtp_meta::*;
+
 // Re-export all the traits in a prelude module, so that applications
 // can always "use gst_rtp::prelude::*" without getting conflicts
 pub mod prelude {

gstreamer-rtp/src/rtp_meta.rs

@@ -0,0 +1,105 @@
+// 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()
+    }
+}