dope-manifold 0.40.0

Owned application and service composition for dope
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

use std::{mem, num};

/// Per-address connection admission chosen before listener construction.
#[derive(Clone, Copy, Eq, PartialEq)]
#[repr(transparent)]
pub struct PerIp(Option<num::NonZero<u32>>);

impl PerIp {
    pub const UNLIMITED: Self = Self(None);

    pub const fn fixed<const CONNECTIONS: u32>() -> Self {
        const { assert!(CONNECTIONS > 0) };
        Self(num::NonZero::new(CONNECTIONS))
    }

    pub const fn limit(self) -> Option<num::NonZero<u32>> {
        self.0
    }
}

impl From<num::NonZero<u32>> for PerIp {
    fn from(limit: num::NonZero<u32>) -> Self {
        Self(Some(limit))
    }
}

const _: () = {
    assert!(mem::size_of::<PerIp>() == mem::size_of::<u32>());
    assert!(mem::align_of::<PerIp>() == mem::align_of::<u32>());
};

pub trait Policy {
    const PER_IP: PerIp;
}

pub struct Standard;

impl Policy for Standard {
    const PER_IP: PerIp = PerIp::fixed::<256>();
}