o3 0.24.0

shared-nothing primitives
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
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107

use std::marker;

use crate::depot::queue::{
    indexed::planes::{map, phase},
    links,
};

/// Exclusive membership authority borrowing only disjoint hooks of one installed record.
pub struct Slot<'a, K, V, const N: usize, P = ()> {
    pub(in crate::depot::queue::indexed::planes::map) core: &'a map::Core<K, V, N>,
    pub(in crate::depot::queue::indexed::planes::map) index: links::Index,
    phase: marker::PhantomData<P>,
}

impl<'a, K, V, const N: usize, P> Slot<'a, K, V, N, P> {
    pub(in crate::depot::queue::indexed::planes::map) fn new(
        core: &'a map::Core<K, V, N>,
        index: links::Index,
    ) -> Self {
        Self {
            core,
            index,
            phase: marker::PhantomData,
        }
    }
    pub(in crate::depot::queue::indexed::planes::map) fn into_phase<Q>(
        self,
    ) -> Slot<'a, K, V, N, Q> {
        Slot::new(self.core, self.index)
    }
}

impl<K, V, const N: usize> Slot<'_, K, V, N> {
    pub(in crate::depot::queue::indexed::planes::map) fn is_linked<const P: usize>(&self) -> bool {
        const { assert!(P > 0 && P < N) };
        self.index
            .is_linked(&unsafe { self.core.node(self.index) }.hooks[P])
    }
}

impl<'a, K, V, const N: usize, const P: usize> Slot<'a, K, V, N, phase::Linked<P>> {
    pub fn unlink(self) -> Slot<'a, K, V, N, phase::Vacant<P>> {
        crate::depot::raw::Membership::<true>::transition(self)
    }
}

impl<'a, K, V, const N: usize, const P: usize> Slot<'a, K, V, N, phase::Vacant<P>> {
    pub fn link_back(self) -> Slot<'a, K, V, N, phase::Linked<P>> {
        crate::depot::raw::Membership::<false>::transition(self)
    }
}

// SAFETY: the slot retains exclusive hook authority and its resolved membership in P.
unsafe impl<'a, K, V, const N: usize, const P: usize> crate::depot::raw::Membership<true>
    for Slot<'a, K, V, N, phase::Linked<P>>
{
    type Output = Slot<'a, K, V, N, phase::Vacant<P>>;

    fn parts(
        &self,
    ) -> (
        &links::Chain<u32>,
        impl crate::depot::raw::Hooks + '_,
        links::Index,
    ) {
        (
            &self.core.queues[P],
            map::Hooks {
                core: self.core,
                plane: P,
            },
            self.index,
        )
    }

    unsafe fn finish(self) -> Self::Output {
        self.into_phase()
    }
}

// SAFETY: the slot retains exclusive hook authority and its resolved vacancy in P.
unsafe impl<'a, K, V, const N: usize, const P: usize> crate::depot::raw::Membership<false>
    for Slot<'a, K, V, N, phase::Vacant<P>>
{
    type Output = Slot<'a, K, V, N, phase::Linked<P>>;

    fn parts(
        &self,
    ) -> (
        &links::Chain<u32>,
        impl crate::depot::raw::Hooks + '_,
        links::Index,
    ) {
        (
            &self.core.queues[P],
            map::Hooks {
                core: self.core,
                plane: P,
            },
            self.index,
        )
    }

    unsafe fn finish(self) -> Self::Output {
        self.into_phase()
    }
}