o3 0.24.1

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

pub(in crate::depot) use block::QueueBlock;

use crate::depot::arena::linked::slots;

mod block;

use crate::depot::queue::{indexed::shared, pool};

pub(in crate::depot) struct QueueSlot<S> {
    pub(in crate::depot) queue: slots::State,
    pub(in crate::depot) state: S,
}

// SAFETY: Live retains this exact allocated, initialized lane and the owner's borrow.
unsafe impl<'a, T, S, const TRACK: bool> crate::depot::raw::Project<usize>
    for &'a pool::Lanes<T, S, TRACK>
{
    type Output = pool::View<'a, T, S, TRACK>;

    unsafe fn project(self, index: usize) -> Self::Output {
        pool::View::new(&self.block.store, unsafe {
            self.block.slots().get_unchecked(index)
        })
    }
}

// SAFETY: Live retains the exclusive original owner and this initialized lane.
unsafe impl<'a, T, S, const TRACK: bool> crate::depot::raw::Project<usize>
    for &'a mut pool::Lanes<T, S, TRACK>
{
    type Output = pool::Lane<'a, T, S, TRACK>;

    unsafe fn project(self, index: usize) -> Self::Output {
        let (store, slots) = self.block.split();
        pool::Lane::new(store, unsafe { slots.get_unchecked_mut(index) })
    }
}

// SAFETY: the initialized-node proof retains this exact allocation and its original borrow.
unsafe impl<'a, T: Copy, P, const N: usize> crate::depot::raw::Project<usize>
    for &'a shared::Fifo<T, P, N>
{
    type Output = shared::Slot<'a, T, P, N>;

    unsafe fn project(self, index: usize) -> Self::Output {
        shared::Slot {
            fifo: self,
            // SAFETY: Project admits an initialized physical node in this exact owner.
            node: unsafe { self.nodes.get_unchecked(index) },
        }
    }
}