gstreamer_audio/subclass/
audio_aggregator_pad.rs

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

gstreamer_audio/subclass/
audio_aggregator_pad.rs
