1// Take a look at the license at the top of the repository in the LICENSE file.
2
3use std::{mem, ptr};
4
5use glib::{prelude::*, translate::*};
6use gst::prelude::*;
7
8use crate::{ffi, BaseSrc};
9
10mod sealed {
11 pub trait Sealed {}
12 impl<T: super::IsA<super::BaseSrc>> Sealed for T {}
13}
14
15pub trait BaseSrcExtManual: sealed::Sealed + IsA<BaseSrc> + 'static {
16 #[doc(alias = "get_allocator")]
17 #[doc(alias = "gst_base_src_get_allocator")]
18 fn allocator(&self) -> (Option<gst::Allocator>, gst::AllocationParams) {
19 unsafe {
20 let mut allocator = ptr::null_mut();
21 let mut params = mem::MaybeUninit::uninit();
22 ffi::gst_base_src_get_allocator(
23 self.as_ref().to_glib_none().0,
24 &mut allocator,
25 params.as_mut_ptr(),
26 );
27 (from_glib_full(allocator), params.assume_init().into())
28 }
29 }
30
31 #[doc(alias = "get_segment")]
32 fn segment(&self) -> gst::Segment {
33 unsafe {
34 let src: &ffi::GstBaseSrc = &*(self.as_ptr() as *const _);
35 let srcpad = self.src_pad();
36 let _guard = srcpad.stream_lock();
37 let _guard = self.as_ref().object_lock();
38 from_glib_none(&src.segment as *const _)
39 }
40 }
41
42 #[doc(alias = "gst_base_src_query_latency")]
43 fn query_latency(
44 &self,
45 ) -> Result<(bool, Option<gst::ClockTime>, Option<gst::ClockTime>), glib::BoolError> {
46 unsafe {
47 let mut live = mem::MaybeUninit::uninit();
48 let mut min_latency = mem::MaybeUninit::uninit();
49 let mut max_latency = mem::MaybeUninit::uninit();
50 let ret = from_glib(ffi::gst_base_src_query_latency(
51 self.as_ref().to_glib_none().0,
52 live.as_mut_ptr(),
53 min_latency.as_mut_ptr(),
54 max_latency.as_mut_ptr(),
55 ));
56 let live = live.assume_init();
57 let min_latency = min_latency.assume_init();
58 let max_latency = max_latency.assume_init();
59 if ret {
60 Ok((
61 from_glib(live),
62 from_glib(min_latency),
63 from_glib(max_latency),
64 ))
65 } else {
66 Err(glib::bool_error!("Failed to query latency"))
67 }
68 }
69 }
70
71 fn src_pad(&self) -> &gst::Pad {
72 unsafe {
73 let elt = &*(self.as_ptr() as *const ffi::GstBaseSrc);
74 &*(&elt.srcpad as *const *mut gst::ffi::GstPad as *const gst::Pad)
75 }
76 }
77}
78
79impl<O: IsA<BaseSrc>> BaseSrcExtManual for O {}
80