gstreamer_audio/subclass/
audio_filter.rs

1// Take a look at the license at the top of the repository in the LICENSE file.
2
3use glib::translate::*;
4use gst_base::{prelude::*, subclass::prelude::*};
5
6use crate::{ffi, AudioFilter, AudioInfo};
7
8pub trait AudioFilterImpl: BaseTransformImpl + ObjectSubclass<Type: IsA<AudioFilter>> {
9    fn allowed_caps() -> &'static gst::Caps {
10        Self::parent_allowed_caps()
11    }
12
13    fn setup(&self, info: &AudioInfo) -> Result<(), gst::LoggableError> {
14        self.parent_setup(info)
15    }
16}
17
18pub trait AudioFilterImplExt: AudioFilterImpl {
19    fn parent_setup(&self, info: &AudioInfo) -> Result<(), gst::LoggableError> {
20        unsafe {
21            let data = Self::type_data();
22            let parent_class = data.as_ref().parent_class() as *mut ffi::GstAudioFilterClass;
23            (*parent_class)
24                .setup
25                .map(|f| {
26                    gst::result_from_gboolean!(
27                        f(
28                            self.obj().unsafe_cast_ref::<AudioFilter>().to_glib_none().0,
29                            info.to_glib_none().0,
30                        ),
31                        gst::CAT_RUST,
32                        "Parent function `setup` failed"
33                    )
34                })
35                .unwrap_or(Ok(()))
36        }
37    }
38
39    fn parent_allowed_caps() -> &'static gst::Caps {
40        unsafe {
41            let data = Self::type_data();
42            let parent_class = data.as_ref().parent_class() as *mut gst::ffi::GstElementClass;
43
44            let templ = gst::ffi::gst_element_class_get_pad_template(
45                parent_class,
46                glib::gstr!("sink").to_glib_none().0,
47            );
48
49            if templ.is_null() {
50                static ANY_AUDIO_CAPS: std::sync::OnceLock<gst::Caps> = std::sync::OnceLock::new();
51
52                return ANY_AUDIO_CAPS.get_or_init(|| crate::AudioCapsBuilder::new().build());
53            }
54
55            &*(&(*templ).caps as *const *mut gst::ffi::GstCaps as *const gst::Caps)
56        }
57    }
58}
59
60impl<T: AudioFilterImpl> AudioFilterImplExt for T {}
61
62unsafe impl<T: AudioFilterImpl> IsSubclassable<T> for AudioFilter {
63    fn class_init(klass: &mut glib::Class<Self>) {
64        Self::parent_class_init::<T>(klass);
65
66        let klass = klass.as_mut();
67        klass.setup = Some(audio_filter_setup::<T>);
68
69        unsafe {
70            ffi::gst_audio_filter_class_add_pad_templates(
71                &mut *klass,
72                T::allowed_caps().to_glib_none().0,
73            );
74        }
75    }
76}
77
78unsafe extern "C" fn audio_filter_setup<T: AudioFilterImpl>(
79    ptr: *mut ffi::GstAudioFilter,
80    info: *const ffi::GstAudioInfo,
81) -> glib::ffi::gboolean {
82    let instance = &*(ptr as *mut T::Instance);
83    let imp = instance.imp();
84
85    gst::panic_to_error!(imp, false, {
86        match imp.setup(&from_glib_none(info)) {
87            Ok(()) => true,
88            Err(err) => {
89                err.log_with_imp(imp);
90                false
91            }
92        }
93    })
94    .into_glib()
95}
gstreamer_audio/subclass/audio_filter.rs

gstreamer_audio/subclass/
audio_filter.rs
