reverie-process 0.4.0

Deterministic async process spawning and management for the Reverie framework.
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
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75

/*
 * Copyright (c) Meta Platforms, Inc. and affiliates.
 * All rights reserved.
 *
 * This source code is licensed under the BSD-style license found in the
 * LICENSE file in the root directory of this source tree.
 */

use std::str::FromStr;

use serde::Deserialize;
use serde::Serialize;

bitflags::bitflags! {
    /// A namespace that may be unshared with [`Command::unshare`].
    ///
    /// [`Command::unshare`]: super::Command::unshare
    #[derive(Deserialize, Serialize, PartialEq, Eq, PartialOrd, Ord, Hash, Debug, Clone, Copy)]
    pub struct Namespace: i32 {
        /// Cgroup namespace.
        const CGROUP = libc::CLONE_NEWCGROUP;
        /// IPC namespace.
        const IPC = libc::CLONE_NEWIPC;
        /// Network namespace.
        const NETWORK = libc::CLONE_NEWNET;
        /// Mount namespace.
        const MOUNT = libc::CLONE_NEWNS;
        /// PID namespace.
        const PID = libc::CLONE_NEWPID;
        /// User and group namespace.
        const USER = libc::CLONE_NEWUSER;
        /// UTS namespace.
        const UTS = libc::CLONE_NEWUTS;
    }
}

impl Default for Namespace {
    fn default() -> Self {
        Self::empty()
    }
}

#[derive(Debug, Clone)]
pub enum ParseNamespaceError {
    InvalidNamespace(String),
}

impl std::error::Error for ParseNamespaceError {}

impl core::fmt::Display for ParseNamespaceError {
    fn fmt(&self, f: &mut core::fmt::Formatter) -> core::fmt::Result {
        match self {
            ParseNamespaceError::InvalidNamespace(ns) => {
                write!(f, "Invalid namespace: {}", ns)
            }
        }
    }
}

impl FromStr for Namespace {
    type Err = ParseNamespaceError;
    fn from_str(s: &str) -> Result<Self, ParseNamespaceError> {
        s.split(',').try_fold(Namespace::empty(), |ns, s| match s {
            "cgroup" => Ok(ns | Namespace::CGROUP),
            "ipc" => Ok(ns | Namespace::IPC),
            "network" => Ok(ns | Namespace::NETWORK),
            "pid" => Ok(ns | Namespace::PID),
            "mount" => Ok(ns | Namespace::MOUNT),
            "user" => Ok(ns | Namespace::USER),
            "uts" => Ok(ns | Namespace::UTS),
            "" | "none" => Ok(ns),
            invalid_ns => Err(ParseNamespaceError::InvalidNamespace(invalid_ns.to_owned())),
        })
    }
}