gstreamer-rs/gstreamer/src/subclass/device_provider.rs

163 lines
5.1 KiB
Rust
Raw Normal View History

// Copyright (C) 2019 Sebastian Dröge <sebastian@centricular.com>
//
// Licensed under the Apache License, Version 2.0 <LICENSE-APACHE or
// http://www.apache.org/licenses/LICENSE-2.0> or the MIT license
// <LICENSE-MIT or http://opensource.org/licenses/MIT>, at your
// option. This file may not be copied, modified, or distributed
// except according to those terms.
use glib_sys;
use gst_sys;
use glib::translate::*;
use glib::subclass::prelude::*;
use Device;
use DeviceProvider;
use DeviceProviderClass;
use LoggableError;
pub trait DeviceProviderImpl: DeviceProviderImplExt + ObjectImpl + Send + Sync {
fn probe(&self, device_provider: &DeviceProvider) -> Vec<Device> {
self.parent_probe(device_provider)
}
fn start(&self, device_provider: &DeviceProvider) -> Result<(), LoggableError> {
self.parent_start(device_provider)
}
fn stop(&self, device_provider: &DeviceProvider) {
self.parent_stop(device_provider)
}
}
pub trait DeviceProviderImplExt {
fn parent_probe(&self, device_provider: &DeviceProvider) -> Vec<Device>;
fn parent_start(&self, device_provider: &DeviceProvider) -> Result<(), LoggableError>;
fn parent_stop(&self, device_provider: &DeviceProvider);
}
impl<T: DeviceProviderImpl> DeviceProviderImplExt for T {
fn parent_probe(&self, device_provider: &DeviceProvider) -> Vec<Device> {
unsafe {
let data = T::type_data();
let parent_class =
data.as_ref().get_parent_class() as *mut gst_sys::GstDeviceProviderClass;
if let Some(f) = (*parent_class).probe {
FromGlibPtrContainer::from_glib_full(f(device_provider.to_glib_none().0))
} else {
Vec::new()
}
}
}
fn parent_start(&self, device_provider: &DeviceProvider) -> Result<(), LoggableError> {
unsafe {
let data = T::type_data();
let parent_class =
data.as_ref().get_parent_class() as *mut gst_sys::GstDeviceProviderClass;
let f = (*parent_class).start.ok_or_else(|| {
gst_loggable_error!(::CAT_RUST, "Parent function `start` is not defined")
})?;
gst_result_from_gboolean!(
f(device_provider.to_glib_none().0),
::CAT_RUST,
"Failed to start the device provider using the parent function"
)
}
}
fn parent_stop(&self, device_provider: &DeviceProvider) {
unsafe {
let data = T::type_data();
let parent_class =
data.as_ref().get_parent_class() as *mut gst_sys::GstDeviceProviderClass;
if let Some(f) = (*parent_class).stop {
f(device_provider.to_glib_none().0);
}
}
}
}
pub unsafe trait DeviceProviderClassSubclassExt: Sized + 'static {
fn set_metadata(
&mut self,
long_name: &str,
classification: &str,
description: &str,
author: &str,
) {
unsafe {
gst_sys::gst_device_provider_class_set_metadata(
self as *mut Self as *mut gst_sys::GstDeviceProviderClass,
long_name.to_glib_none().0,
classification.to_glib_none().0,
description.to_glib_none().0,
author.to_glib_none().0,
);
}
}
fn add_metadata(&mut self, key: &str, value: &str) {
unsafe {
gst_sys::gst_device_provider_class_add_metadata(
self as *mut Self as *mut gst_sys::GstDeviceProviderClass,
key.to_glib_none().0,
value.to_glib_none().0,
);
}
}
}
unsafe impl DeviceProviderClassSubclassExt for DeviceProviderClass {}
unsafe impl<T: DeviceProviderImpl> IsSubclassable<T> for DeviceProvider {
fn override_vfuncs(klass: &mut glib::Class<Self>) {
<glib::Object as IsSubclassable<T>>::override_vfuncs(klass);
let klass = klass.as_mut();
klass.probe = Some(device_provider_probe::<T>);
klass.start = Some(device_provider_start::<T>);
klass.stop = Some(device_provider_stop::<T>);
}
}
unsafe extern "C" fn device_provider_probe<T: DeviceProviderImpl>(
ptr: *mut gst_sys::GstDeviceProvider,
) -> *mut glib_sys::GList {
let instance = &*(ptr as *mut T::Instance);
let imp = instance.get_impl();
let wrap: Borrowed<DeviceProvider> = from_glib_borrow(ptr);
imp.probe(&wrap).to_glib_full()
}
unsafe extern "C" fn device_provider_start<T: DeviceProviderImpl>(
ptr: *mut gst_sys::GstDeviceProvider,
) -> glib_sys::gboolean {
let instance = &*(ptr as *mut T::Instance);
let imp = instance.get_impl();
let wrap: Borrowed<DeviceProvider> = from_glib_borrow(ptr);
match imp.start(&wrap) {
Ok(()) => true,
Err(err) => {
err.log_with_object(&*wrap);
false
}
}
.to_glib()
}
unsafe extern "C" fn device_provider_stop<T: DeviceProviderImpl>(
ptr: *mut gst_sys::GstDeviceProvider,
) {
let instance = &*(ptr as *mut T::Instance);
let imp = instance.get_impl();
let wrap: Borrowed<DeviceProvider> = from_glib_borrow(ptr);
imp.stop(&wrap);
}