moirai-core 0.7.0

Core abstractions and traits for the Moirai concurrency library
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

use core::fmt;

/// IPC-specific error type to minimize dependencies
#[derive(Debug, Clone, PartialEq, Eq)]
pub enum IpcError {
    /// System error with error code
    SystemError(i32),
    /// Invalid argument
    InvalidArgument,
    /// The name is already taken by a live segment
    AlreadyExists,
    /// Another handle already holds this endpoint of the queue
    EndpointInUse,
    /// Resource not found
    NotFound,
    /// Permission denied
    PermissionDenied,
}

impl fmt::Display for IpcError {
    fn fmt(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result {
        match self {
            IpcError::SystemError(code) => write!(f, "System error: {code}"),
            IpcError::InvalidArgument => write!(f, "Invalid argument"),
            IpcError::AlreadyExists => write!(f, "Segment already exists"),
            IpcError::EndpointInUse => write!(f, "Queue endpoint already in use"),
            IpcError::NotFound => write!(f, "Resource not found"),
            IpcError::PermissionDenied => write!(f, "Permission denied"),
        }
    }
}

impl core::error::Error for IpcError {}

/// Convert the calling thread's last operating-system error to `IpcError`.
#[cfg(any(unix, windows))]
pub fn last_os_error() -> IpcError {
    let code = std::io::Error::last_os_error()
        .raw_os_error()
        .expect("invariant: last_os_error captures a raw operating-system error code");
    IpcError::SystemError(code)
}