compio-driver 0.12.0-rc.1

Low-level driver for compio
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47

use std::{
    any::Any,
    error::Error,
    fmt::{Debug, Display},
    io,
    panic::{UnwindSafe, catch_unwind, resume_unwind},
};

pub(crate) struct Panic(Box<dyn Any + Send>);

// Panic is unconditionally `Sync`
unsafe impl Sync for Panic {}

impl Display for Panic {
    fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
        Debug::fmt(self, f)
    }
}

impl Debug for Panic {
    fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
        f.debug_tuple("Panic").finish_non_exhaustive()
    }
}

impl Error for Panic {}

impl From<Panic> for io::Error {
    fn from(value: Panic) -> Self {
        Self::other(value)
    }
}

pub(crate) fn catch_unwind_io<F, R>(f: F) -> io::Result<R>
where
    F: FnOnce() -> io::Result<R> + UnwindSafe,
{
    catch_unwind(f).map_err(|err| io::Error::from(Panic(err)))?
}

pub(crate) fn resume_unwind_io<T>(res: io::Result<T>) -> io::Result<T> {
    let Err(e) = res else { return res };
    match e.downcast::<Panic>() {
        Ok(p) => resume_unwind(p.0),
        Err(e) => Err(e),
    }
}