dope-net 0.42.0

Owned network transports for dope
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
58
59
60
61

use dope_core::driver::{receive::credit, route::Identity};

use crate::{
    link::pool::{
        change::drain,
        recv::{self, storage, storage::tail},
    },
    wire::{
        self,
        receive::{Policy, mode, reserve},
    },
};

pub(in crate::link::pool::change) trait Strategy<W: wire::Spec>:
    Sized + storage::raw::Mode + drain::Strategy<W>
{
    fn credits<'a, 'd, ID: Identity, T, S, R>(
        _: &'a tail::Table<T, ID, S, recv::State<'d, ID, Self, R>>,
    ) -> Option<&'a credit::Storage<'d>> {
        None
    }
}

impl<W> Strategy<W> for mode::Disabled
where
    W: wire::Spec,
    <W::Receive as Policy<W>>::Reserve: reserve::Immediate<W>,
{
}

impl<W> Strategy<W> for mode::Parking
where
    W: wire::Spec,
    <W::Receive as Policy<W>>::Reserve: reserve::Immediate<W>,
{
}

impl<W> Strategy<W> for mode::Enabled
where
    W: wire::Spec,
    <W::Receive as Policy<W>>::Reserve: reserve::Immediate<W>,
{
    fn credits<'a, 'd, ID: Identity, T, S, R>(
        slab: &'a tail::Table<T, ID, S, recv::State<'d, ID, Self, R>>,
    ) -> Option<&'a credit::Storage<'d>> {
        Some(slab.credit())
    }
}

impl<W, R> Strategy<W> for mode::Waiting<R>
where
    W: wire::Spec,
    R: reserve::Try<W>,
    W::Receive: Policy<W, Reserve = reserve::Waiting<R>>,
{
    fn credits<'a, 'd, ID: Identity, T, S, C>(
        slab: &'a tail::Table<T, ID, S, recv::State<'d, ID, Self, C>>,
    ) -> Option<&'a credit::Storage<'d>> {
        Some(slab.credit())
    }
}