gstreamer_base/
base_sink.rs

1// Take a look at the license at the top of the repository in the LICENSE file.
2
3use std::mem;
4
5use glib::{prelude::*, translate::*};
6use gst::prelude::*;
7
8use crate::{ffi, BaseSink};
9
10mod sealed {
11    pub trait Sealed {}
12    impl<T: super::IsA<super::BaseSink>> Sealed for T {}
13}
14
15pub trait BaseSinkExtManual: sealed::Sealed + IsA<BaseSink> + 'static {
16    #[doc(alias = "get_segment")]
17    fn segment(&self) -> gst::Segment {
18        unsafe {
19            let sink: &ffi::GstBaseSink = &*(self.as_ptr() as *const _);
20            let sinkpad = self.sink_pad();
21            let _guard = sinkpad.stream_lock();
22            from_glib_none(&sink.segment as *const gst::ffi::GstSegment)
23        }
24    }
25
26    #[doc(alias = "gst_base_sink_query_latency")]
27    fn query_latency(
28        &self,
29    ) -> Result<(bool, bool, Option<gst::ClockTime>, Option<gst::ClockTime>), glib::BoolError> {
30        unsafe {
31            let mut live = mem::MaybeUninit::uninit();
32            let mut upstream_live = mem::MaybeUninit::uninit();
33            let mut min_latency = mem::MaybeUninit::uninit();
34            let mut max_latency = mem::MaybeUninit::uninit();
35            let ret = from_glib(ffi::gst_base_sink_query_latency(
36                self.as_ref().to_glib_none().0,
37                live.as_mut_ptr(),
38                upstream_live.as_mut_ptr(),
39                min_latency.as_mut_ptr(),
40                max_latency.as_mut_ptr(),
41            ));
42            let live = live.assume_init();
43            let upstream_live = upstream_live.assume_init();
44            let min_latency = min_latency.assume_init();
45            let max_latency = max_latency.assume_init();
46            if ret {
47                Ok((
48                    from_glib(live),
49                    from_glib(upstream_live),
50                    from_glib(min_latency),
51                    from_glib(max_latency),
52                ))
53            } else {
54                Err(glib::bool_error!("Failed to query latency"))
55            }
56        }
57    }
58
59    fn sink_pad(&self) -> &gst::Pad {
60        unsafe {
61            let elt = &*(self.as_ptr() as *const ffi::GstBaseSink);
62            &*(&elt.sinkpad as *const *mut gst::ffi::GstPad as *const gst::Pad)
63        }
64    }
65}
66
67impl<O: IsA<BaseSink>> BaseSinkExtManual for O {}
gstreamer_base/base_sink.rs

gstreamer_base/
base_sink.rs
