mirror of
https://gitlab.freedesktop.org/gstreamer/gstreamer-rs.git
synced 2025-02-27 16:26:22 +00:00
827ff99965
In gir it was brought up [1] that some traits (in particular
`*ExtManual`) are exported from the crate root in addition to the
prelude, cluttering the environment unnecessarily. This commit removes
all these reexports, leaving those in prelude (that were already there)
only.
After this commit everything matching `Ext(Manual)?\b` in `lib.rs` sits
within `pub mod prelude {};`.
[1]: https://github.com/gtk-rs/gir/pull/1111
69 lines
2.3 KiB
Rust
69 lines
2.3 KiB
Rust
// Take a look at the license at the top of the repository in the LICENSE file.
|
|
|
|
use thiserror::Error;
|
|
|
|
use crate::ErrorMessage;
|
|
use crate::FlowReturn;
|
|
|
|
#[macro_export]
|
|
macro_rules! panic_to_error(
|
|
($element:expr, $panicked:expr, $ret:expr, $code:block) => {{
|
|
use std::panic::{self, AssertUnwindSafe};
|
|
use std::sync::atomic::Ordering;
|
|
use $crate::prelude::ElementExtManual;
|
|
|
|
#[allow(clippy::unused_unit)]
|
|
{
|
|
if $panicked.load(Ordering::Relaxed) {
|
|
$element.post_error_message($crate::error_msg!($crate::LibraryError::Failed, ["Panicked"]));
|
|
$ret
|
|
} else {
|
|
let result = panic::catch_unwind(AssertUnwindSafe(|| $code));
|
|
|
|
match result {
|
|
Ok(result) => result,
|
|
Err(err) => {
|
|
$panicked.store(true, Ordering::Relaxed);
|
|
if let Some(cause) = err.downcast_ref::<&str>() {
|
|
$element.post_error_message($crate::error_msg!($crate::LibraryError::Failed, ["Panicked: {}", cause]));
|
|
} else if let Some(cause) = err.downcast_ref::<String>() {
|
|
$element.post_error_message($crate::error_msg!($crate::LibraryError::Failed, ["Panicked: {}", cause]));
|
|
} else {
|
|
$element.post_error_message($crate::error_msg!($crate::LibraryError::Failed, ["Panicked"]));
|
|
}
|
|
$ret
|
|
}
|
|
}
|
|
}
|
|
}
|
|
}};
|
|
);
|
|
|
|
#[derive(Clone, Debug, PartialEq, Eq, Error)]
|
|
pub enum FlowError {
|
|
#[error("Flushing")]
|
|
Flushing,
|
|
#[error("Eos")]
|
|
Eos,
|
|
#[error("Not Negotiated")]
|
|
NotNegotiated(ErrorMessage),
|
|
#[error("Error")]
|
|
Error(ErrorMessage),
|
|
}
|
|
|
|
impl From<FlowError> for FlowReturn {
|
|
fn from(err: FlowError) -> Self {
|
|
FlowReturn::from(&err)
|
|
}
|
|
}
|
|
|
|
impl<'a> From<&'a FlowError> for FlowReturn {
|
|
fn from(err: &FlowError) -> FlowReturn {
|
|
match *err {
|
|
FlowError::Flushing => FlowReturn::Flushing,
|
|
FlowError::Eos => FlowReturn::Eos,
|
|
FlowError::NotNegotiated(..) => FlowReturn::NotNegotiated,
|
|
FlowError::Error(..) => FlowReturn::Error,
|
|
}
|
|
}
|
|
}
|