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
10pub trait BaseSinkExtManual: IsA<BaseSink> + 'static {
11    #[doc(alias = "get_segment")]
12    fn segment(&self) -> gst::Segment {
13        unsafe {
14            let sink: &ffi::GstBaseSink = &*(self.as_ptr() as *const _);
15            let sinkpad = self.sink_pad();
16            let _guard = sinkpad.stream_lock();
17            from_glib_none(&sink.segment as *const gst::ffi::GstSegment)
18        }
19    }
20
21    #[doc(alias = "gst_base_sink_query_latency")]
22    fn query_latency(
23        &self,
24    ) -> Result<(bool, bool, Option<gst::ClockTime>, Option<gst::ClockTime>), glib::BoolError> {
25        unsafe {
26            let mut live = mem::MaybeUninit::uninit();
27            let mut upstream_live = mem::MaybeUninit::uninit();
28            let mut min_latency = mem::MaybeUninit::uninit();
29            let mut max_latency = mem::MaybeUninit::uninit();
30            let ret = from_glib(ffi::gst_base_sink_query_latency(
31                self.as_ref().to_glib_none().0,
32                live.as_mut_ptr(),
33                upstream_live.as_mut_ptr(),
34                min_latency.as_mut_ptr(),
35                max_latency.as_mut_ptr(),
36            ));
37            let live = live.assume_init();
38            let upstream_live = upstream_live.assume_init();
39            let min_latency = min_latency.assume_init();
40            let max_latency = max_latency.assume_init();
41            if ret {
42                Ok((
43                    from_glib(live),
44                    from_glib(upstream_live),
45                    from_glib(min_latency),
46                    from_glib(max_latency),
47                ))
48            } else {
49                Err(glib::bool_error!("Failed to query latency"))
50            }
51        }
52    }
53
54    fn sink_pad(&self) -> &gst::Pad {
55        unsafe {
56            let elt = &*(self.as_ptr() as *const ffi::GstBaseSink);
57            &*(&elt.sinkpad as *const *mut gst::ffi::GstPad as *const gst::Pad)
58        }
59    }
60}
61
62impl<O: IsA<BaseSink>> BaseSinkExtManual for O {}
gstreamer_base/base_sink.rs

gstreamer_base/
base_sink.rs
