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 {}
68