dope-sys 0.41.0

Typed operating-system call contracts
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

use o3::{base::num::bounded, depot::capacity};

use crate::io::{
    reactor::{
        Full, complete,
        submit::{self, Ready},
    },
    socket::option::tuning,
};

/// An exclusive view of locally staged native submissions.
pub trait Queue<'q, T: complete::raw::Token>: Sized {
    type Owned;
    type Vacancy: submit::raw::Vacancy<'q, T, Owned = Self::Owned>;
    type Reserved<const N: usize>: tuning::raw::Chain<T, N>;
    type Prepared<'e, E: 'e, const N: usize>: Ready;

    fn refresh(&mut self);
    fn len(&self) -> bounded::U32<0, { u32::MAX }>;
    fn is_empty(&self) -> bool;
    fn try_one(self) -> Result<Self::Vacancy, Full>;
    /// Acquires the current kernel head without publishing local submissions.
    /// A full queue leaves both cached and shared queue state unchanged.
    fn try_acquire(self) -> Result<Self::Vacancy, Full>;
    fn try_reserve<const N: usize>(
        self,
        count: capacity::Limit<N>,
    ) -> Result<Self::Reserved<N>, Full>;
    fn prepare<'e, const N: usize>(
        self,
        entries: &'e [Self::Owned; N],
    ) -> Result<Self::Prepared<'e, Self::Owned, N>, Full>;
}