dope-net 0.28.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
49
50
51
52
53
54
55
56
57

use dope_core::{
    driver::{receive::Exhausted, route::Identity},
    io::event::net::recv,
};
use receive::eof;

use crate::{
    link::slot::types,
    wire::{self, receive, terminal},
};

pub(in crate::link) enum Retirement<'d> {
    Ready,
    Failed(dope_core::Errno),
    Exhausted(Exhausted<'d>),
    Starved(recv::Retryable),
}

pub(in crate::link) trait Capture<W: wire::Spec> {
    fn capture<'w, 'd, ID: Identity + 'w>(conn: &mut types::Control<'w, 'd, ID, W>)
    where
        W: 'w,
        'd: 'w;
}

impl<W: wire::Spec> Capture<W> for eof::Clean {
    fn capture<'w, 'd, ID: Identity + 'w>(conn: &mut types::Control<'w, 'd, ID, W>)
    where
        W: 'w,
        'd: 'w,
    {
        conn.engine.operations.recv.pause();
    }
}

impl<W> Capture<W> for eof::State
where
    W: wire::Spec,
    W::Receive: eof::Eof<W>,
{
    fn capture<'w, 'd, ID: Identity + 'w>(conn: &mut types::Control<'w, 'd, ID, W>)
    where
        W: 'w,
        'd: 'w,
    {
        if conn.is_recv_done() {
            return;
        }
        let end = match conn.engine.send(&mut conn.terminal) {
            terminal::Admission::Open(end) => end,
            terminal::Admission::Closed => return,
        };
        let done = <W::Receive as eof::Eof<W>>::eof::<ID>(&mut conn.wire, end);
        let ((), captured) = done.into_parts();
        conn.engine.captured(captured);
    }
}