gstreamer_base/subclass/
aggregator_pad.rs

1// Take a look at the license at the top of the repository in the LICENSE file.
2
3use glib::{prelude::*, translate::*};
4use gst::subclass::prelude::*;
5
6use crate::{ffi, Aggregator, AggregatorPad};
7
8pub trait AggregatorPadImpl: PadImpl + ObjectSubclass<Type: IsA<AggregatorPad>> {
9    fn flush(&self, aggregator: &Aggregator) -> Result<gst::FlowSuccess, gst::FlowError> {
10        self.parent_flush(aggregator)
11    }
12
13    fn skip_buffer(&self, aggregator: &Aggregator, buffer: &gst::Buffer) -> bool {
14        self.parent_skip_buffer(aggregator, buffer)
15    }
16}
17
18pub trait AggregatorPadImplExt: AggregatorPadImpl {
19    fn parent_flush(&self, aggregator: &Aggregator) -> Result<gst::FlowSuccess, gst::FlowError> {
20        unsafe {
21            let data = Self::type_data();
22            let parent_class = data.as_ref().parent_class() as *mut ffi::GstAggregatorPadClass;
23            (*parent_class)
24                .flush
25                .map(|f| {
26                    try_from_glib(f(
27                        self.obj()
28                            .unsafe_cast_ref::<AggregatorPad>()
29                            .to_glib_none()
30                            .0,
31                        aggregator.to_glib_none().0,
32                    ))
33                })
34                .unwrap_or(Ok(gst::FlowSuccess::Ok))
35        }
36    }
37
38    fn parent_skip_buffer(&self, aggregator: &Aggregator, buffer: &gst::Buffer) -> bool {
39        unsafe {
40            let data = Self::type_data();
41            let parent_class = data.as_ref().parent_class() as *mut ffi::GstAggregatorPadClass;
42            (*parent_class)
43                .skip_buffer
44                .map(|f| {
45                    from_glib(f(
46                        self.obj()
47                            .unsafe_cast_ref::<AggregatorPad>()
48                            .to_glib_none()
49                            .0,
50                        aggregator.to_glib_none().0,
51                        buffer.to_glib_none().0,
52                    ))
53                })
54                .unwrap_or(false)
55        }
56    }
57}
58
59impl<T: AggregatorPadImpl> AggregatorPadImplExt for T {}
60unsafe impl<T: AggregatorPadImpl> IsSubclassable<T> for AggregatorPad {
61    fn class_init(klass: &mut glib::Class<Self>) {
62        Self::parent_class_init::<T>(klass);
63        let klass = klass.as_mut();
64        klass.flush = Some(aggregator_pad_flush::<T>);
65        klass.skip_buffer = Some(aggregator_pad_skip_buffer::<T>);
66    }
67}
68
69unsafe extern "C" fn aggregator_pad_flush<T: AggregatorPadImpl>(
70    ptr: *mut ffi::GstAggregatorPad,
71    aggregator: *mut ffi::GstAggregator,
72) -> gst::ffi::GstFlowReturn {
73    let instance = &*(ptr as *mut T::Instance);
74    let imp = instance.imp();
75
76    let res: gst::FlowReturn = imp.flush(&from_glib_borrow(aggregator)).into();
77    res.into_glib()
78}
79
80unsafe extern "C" fn aggregator_pad_skip_buffer<T: AggregatorPadImpl>(
81    ptr: *mut ffi::GstAggregatorPad,
82    aggregator: *mut ffi::GstAggregator,
83    buffer: *mut gst::ffi::GstBuffer,
84) -> glib::ffi::gboolean {
85    let instance = &*(ptr as *mut T::Instance);
86    let imp = instance.imp();
87
88    imp.skip_buffer(&from_glib_borrow(aggregator), &from_glib_borrow(buffer))
89        .into_glib()
90}
gstreamer_base/subclass/aggregator_pad.rs

gstreamer_base/subclass/
aggregator_pad.rs
