dope-net 0.15.0

The manifold runtime
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

use std::io;

use crate::wire::{self, receive};

pub struct Borrowed;
pub struct Retained;

pub trait Mode<W: wire::Wire> {
    #[doc(hidden)]
    type Kind;

    #[doc(hidden)]
    const DEFERS: bool;

    #[doc(hidden)]
    fn deferred_capacity(connections: usize, buffers: usize) -> io::Result<(usize, usize)> {
        if !Self::DEFERS {
            return Ok((0, 0));
        }
        let events = buffers.checked_add(connections).ok_or_else(|| {
            io::Error::new(
                io::ErrorKind::InvalidInput,
                "dope: deferred receive capacity overflow",
            )
        })?;
        Ok((connections, events))
    }
}

impl<W: wire::Wire> Mode<W> for Borrowed {
    type Kind = Self;

    const DEFERS: bool = <W::Receive as receive::Strategy<W>>::BACKPRESSURE;
}

impl<W: wire::Wire> Mode<W> for Retained {
    type Kind = Self;

    const DEFERS: bool = W::RECV_CREDIT || <W::Receive as receive::Strategy<W>>::BACKPRESSURE;
}