gstreamer_audio/subclass/
audio_aggregator_pad.rs

Help
1// Take a look at the license at the top of the repository in the LICENSE file.
2
3use std::ptr;
4
5use glib::translate::*;
6use gst_base::{prelude::*, subclass::prelude::*};
7
8use crate::{ffi, AudioAggregatorPad};
9
10pub trait AudioAggregatorPadImpl: AudioAggregatorPadImplExt + AggregatorPadImpl {
11    const HANDLE_CONVERSION: bool = false;
12
13    /// Called when either the input or output
14    ///  formats have changed.
15    fn update_conversion_info(&self) {
16        self.parent_update_conversion_info()
17    }
18
19    /// Convert a buffer from one format to another.
20    fn convert_buffer(
21        &self,
22        in_info: &crate::AudioInfo,
23        out_info: &crate::AudioInfo,
24        buffer: &gst::Buffer,
25    ) -> Option<gst::Buffer> {
26        self.parent_convert_buffer(in_info, out_info, buffer)
27    }
28}
29
30mod sealed {
31    pub trait Sealed {}
32    impl<T: super::AudioAggregatorPadImplExt> Sealed for T {}
33}
34
35pub trait AudioAggregatorPadImplExt: sealed::Sealed + ObjectSubclass {
36    fn parent_update_conversion_info(&self) {
37        unsafe {
38            let data = Self::type_data();
39            let parent_class = data.as_ref().parent_class() as *mut ffi::GstAudioAggregatorPadClass;
40            if let Some(f) = (*parent_class).update_conversion_info {
41                f(self
42                    .obj()
43                    .unsafe_cast_ref::<AudioAggregatorPad>()
44                    .to_glib_none()
45                    .0);
46            }
47        }
48    }
49
50    fn parent_convert_buffer(
51        &self,
52        in_info: &crate::AudioInfo,
53        out_info: &crate::AudioInfo,
54        buffer: &gst::Buffer,
55    ) -> Option<gst::Buffer> {
56        unsafe {
57            let data = Self::type_data();
58            let parent_class = data.as_ref().parent_class() as *mut ffi::GstAudioAggregatorPadClass;
59            let f = (*parent_class)
60                .convert_buffer
61                .expect("Missing parent function `convert_buffer`");
62            from_glib_full(f(
63                self.obj()
64                    .unsafe_cast_ref::<AudioAggregatorPad>()
65                    .to_glib_none()
66                    .0,
67                mut_override(in_info.to_glib_none().0),
68                mut_override(out_info.to_glib_none().0),
69                buffer.as_mut_ptr(),
70            ))
71        }
72    }
73}
74
75impl<T: AudioAggregatorPadImpl> AudioAggregatorPadImplExt for T {}
76
77unsafe impl<T: AudioAggregatorPadImpl> IsSubclassable<T> for AudioAggregatorPad {
78    fn class_init(klass: &mut glib::Class<Self>) {
79        Self::parent_class_init::<T>(klass);
80
81        let klass = klass.as_mut();
82        if T::HANDLE_CONVERSION {
83            klass.update_conversion_info = Some(audio_aggregator_pad_update_conversion_info::<T>);
84            klass.convert_buffer = Some(audio_aggregator_pad_convert_buffer::<T>);
85        }
86    }
87}
88
89unsafe extern "C" fn audio_aggregator_pad_update_conversion_info<T: AudioAggregatorPadImpl>(
90    ptr: *mut ffi::GstAudioAggregatorPad,
91) {
92    let instance = &*(ptr as *mut T::Instance);
93    let imp = instance.imp();
94
95    imp.update_conversion_info();
96}
97
98unsafe extern "C" fn audio_aggregator_pad_convert_buffer<T: AudioAggregatorPadImpl>(
99    ptr: *mut ffi::GstAudioAggregatorPad,
100    in_info: *mut ffi::GstAudioInfo,
101    out_info: *mut ffi::GstAudioInfo,
102    buffer: *mut gst::ffi::GstBuffer,
103) -> *mut gst::ffi::GstBuffer {
104    let instance = &*(ptr as *mut T::Instance);
105    let imp = instance.imp();
106
107    imp.convert_buffer(
108        &from_glib_none(in_info),
109        &from_glib_none(out_info),
110        &from_glib_borrow(buffer),
111    )
112    .map(|buffer| buffer.into_glib_ptr())
113    .unwrap_or(ptr::null_mut())
114}
gstreamer_audio/subclass/audio_aggregator_pad.rs

gstreamer_audio/subclass/
audio_aggregator_pad.rs
