dope-net 0.20.0

Owned network transports for dope
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

use o3::depot::{arena::linked::slots, queue::pool};
use pool::Front;

use crate::link::event;

pub enum Push<'a, 'd, T = event::Completion<'d>> {
    Ready {
        vacant: slots::Vacant<event::Completion<'d>, slots::Bound<'a, event::Completion<'d>>>,
        done: T,
    },
    Full(T),
}

pub trait Ops<'d> {
    fn prepare_pop(&mut self) -> Option<Front<'_, event::Completion<'d>, ()>>;
    fn has_queued(&self) -> bool;
}

pub trait Write<'d>: Ops<'d> {
    fn prepare_push<T>(&mut self, done: T) -> Push<'_, 'd, T>;
}

impl<'d> Ops<'d> for &mut () {
    fn prepare_pop(&mut self) -> Option<Front<'_, event::Completion<'d>, ()>> {
        None
    }
    fn has_queued(&self) -> bool {
        false
    }
}

impl<'d> Ops<'d> for pool::Lane<'_, event::Completion<'d>> {
    fn prepare_pop(&mut self) -> Option<Front<'_, event::Completion<'d>, ()>> {
        self.front_mut()
    }
    fn has_queued(&self) -> bool {
        !self.is_empty()
    }
}

impl<'d> Write<'d> for pool::Lane<'_, event::Completion<'d>> {
    fn prepare_push<T>(&mut self, done: T) -> Push<'_, 'd, T> {
        match self.vacant() {
            Some(vacant) => Push::Ready { vacant, done },
            None => Push::Full(done),
        }
    }
}