gstreamer_gl/subclass/
gl_base_src.rs

Help
1use ffi::{GstGLBaseSrc, GstGLMemory};
2use glib::translate::*;
3use gst::{result_from_gboolean, LoggableError, CAT_RUST};
4use gst_base::subclass::prelude::*;
5
6use crate::{ffi, prelude::*, GLBaseSrc, GLMemory, GLAPI};
7
8pub trait GLBaseSrcImpl: GLBaseSrcImplExt + PushSrcImpl {
9    const SUPPORTED_GL_API: GLAPI;
10
11    /// called in the GL thread to setup the element GL state.
12    fn gl_start(&self) -> Result<(), LoggableError> {
13        self.parent_gl_start()
14    }
15
16    /// called in the GL thread to setup the element GL state.
17    fn gl_stop(&self) {
18        self.parent_gl_stop()
19    }
20
21    /// called in the GL thread to fill the current video texture.
22    fn fill_gl_memory(&self, memory: &GLMemory) -> Result<(), LoggableError> {
23        self.parent_fill_gl_memory(memory)
24    }
25}
26
27mod sealed {
28    pub trait Sealed {}
29    impl<T: super::GLBaseSrcImplExt> Sealed for T {}
30}
31
32pub trait GLBaseSrcImplExt: sealed::Sealed + ObjectSubclass {
33    fn parent_gl_start(&self) -> Result<(), LoggableError> {
34        unsafe {
35            let data = Self::type_data();
36            let parent_class = data.as_ref().parent_class() as *mut ffi::GstGLBaseSrcClass;
37
38            (*parent_class)
39                .gl_start
40                .map(|f| {
41                    result_from_gboolean!(
42                        f(self.obj().unsafe_cast_ref::<GLBaseSrc>().to_glib_none().0),
43                        CAT_RUST,
44                        "Parent function `gl_start` failed",
45                    )
46                })
47                .unwrap_or(Ok(()))
48        }
49    }
50
51    fn parent_gl_stop(&self) {
52        unsafe {
53            let data = Self::type_data();
54            let parent_class = data.as_ref().parent_class() as *mut ffi::GstGLBaseSrcClass;
55
56            if let Some(f) = (*parent_class).gl_stop {
57                f(self.obj().unsafe_cast_ref::<GLBaseSrc>().to_glib_none().0)
58            }
59        }
60    }
61
62    fn parent_fill_gl_memory(&self, memory: &GLMemory) -> Result<(), LoggableError> {
63        unsafe {
64            let data = Self::type_data();
65            let parent_class = data.as_ref().parent_class() as *mut ffi::GstGLBaseSrcClass;
66
67            (*parent_class)
68                .fill_gl_memory
69                .map(|f| {
70                    result_from_gboolean!(
71                        f(
72                            self.obj().unsafe_cast_ref::<GLBaseSrc>().to_glib_none().0,
73                            mut_override(memory.to_glib_none().0),
74                        ),
75                        CAT_RUST,
76                        "Parent function `fill_gl_memory` failed",
77                    )
78                })
79                .unwrap_or(Ok(()))
80        }
81    }
82}
83
84impl<T: GLBaseSrcImpl> GLBaseSrcImplExt for T {}
85
86unsafe impl<T: GLBaseSrcImpl> IsSubclassable<T> for GLBaseSrc {
87    fn class_init(klass: &mut glib::Class<Self>) {
88        Self::parent_class_init::<T>(klass);
89        let klass = klass.as_mut();
90        klass.supported_gl_api = T::SUPPORTED_GL_API.into_glib();
91        klass.gl_start = Some(gl_start::<T>);
92        klass.gl_stop = Some(gl_stop::<T>);
93        klass.fill_gl_memory = Some(fill_gl_memory::<T>);
94    }
95}
96
97unsafe extern "C" fn gl_start<T: GLBaseSrcImpl>(ptr: *mut GstGLBaseSrc) -> glib::ffi::gboolean {
98    let instance = &*(ptr as *mut T::Instance);
99    let imp = instance.imp();
100
101    gst::panic_to_error!(imp, false, {
102        match imp.gl_start() {
103            Ok(()) => true,
104            Err(err) => {
105                err.log_with_imp(imp);
106                false
107            }
108        }
109    })
110    .into_glib()
111}
112
113unsafe extern "C" fn gl_stop<T: GLBaseSrcImpl>(ptr: *mut GstGLBaseSrc) {
114    let instance = &*(ptr as *mut T::Instance);
115    let imp = instance.imp();
116
117    gst::panic_to_error!(imp, (), { imp.gl_stop() })
118}
119
120unsafe extern "C" fn fill_gl_memory<T: GLBaseSrcImpl>(
121    ptr: *mut GstGLBaseSrc,
122    memory: *mut GstGLMemory,
123) -> glib::ffi::gboolean {
124    let instance = &*(ptr as *mut T::Instance);
125    let imp = instance.imp();
126
127    gst::panic_to_error!(imp, false, {
128        match imp.fill_gl_memory(&from_glib_borrow(memory)) {
129            Ok(()) => true,
130            Err(err) => {
131                err.log_with_imp(imp);
132                false
133            }
134        }
135    })
136    .into_glib()
137}
gstreamer_gl/subclass/gl_base_src.rs

gstreamer_gl/subclass/
gl_base_src.rs
