o3 0.16.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

use std::marker;

use crate::collections::slab::{key, sealed};

pub struct VacantEntry<
    'a,
    T,
    Tag = (),
    const MAX: u32 = { u32::MAX },
    const RECYCLE: bool = false,
    const PARTITIONS: usize = 1,
> {
    pub(in crate::collections::slab::sealed) slab:
        &'a sealed::Exclusive<T, Tag, MAX, RECYCLE, PARTITIONS>,
    pub(in crate::collections::slab::sealed) ticket:
        Option<sealed::core::Ticket<key::Generation<MAX>>>,
}

impl<'a, T, Tag, const MAX: u32, const RECYCLE: bool, const PARTITIONS: usize>
    VacantEntry<'a, T, Tag, MAX, RECYCLE, PARTITIONS>
{
    pub fn key(&self) -> key::Handle<Tag, MAX> {
        let ticket = unsafe { self.ticket.unwrap_unchecked() };
        key::Handle::new(ticket.index.get(), ticket.generation)
    }

    pub fn insert(mut self, value: T) -> key::Handle<Tag, MAX> {
        let ticket = unsafe { self.ticket.unwrap_unchecked() };
        let key = key::Handle::new(ticket.index.get(), ticket.generation);
        let ticket = unsafe { self.ticket.take().unwrap_unchecked() };
        self.slab.core.reservations().commit(ticket, value);
        key
    }

    pub fn insert_occupied(
        mut self,
        value: T,
    ) -> sealed::OccupiedEntry<'a, T, Tag, MAX, RECYCLE, PARTITIONS> {
        let ticket = unsafe { self.ticket.take().unwrap_unchecked() };
        let slab = self.slab;
        slab.core.reservations().commit(ticket, value);
        sealed::OccupiedEntry {
            busy: sealed::core::Busy::take_committed(&slab.core, ticket),
            tag: marker::PhantomData,
        }
    }
}

impl<T, Tag, const MAX: u32, const RECYCLE: bool, const PARTITIONS: usize> Drop
    for VacantEntry<'_, T, Tag, MAX, RECYCLE, PARTITIONS>
{
    fn drop(&mut self) {
        if let Some(ticket) = self.ticket.take() {
            self.slab.core.reservations().rollback(ticket);
        }
    }
}