dope-manifold 0.30.0

Owned application and service composition 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
58

use dope_core::driver::route::{Identity, KeyTag};
use o3::base::cell::region;

use crate::client::{app, session};

pub struct Ready;
pub struct Application;

/// Selects a drain remainder only where the concrete session proves it valid.
pub trait Mode<'d, ID: Identity, N> {
    fn select<'session, 'barrier, 'region>(
        session: &'session N,
        barrier: app::Barrier<'barrier, 'd, ID>,
        region: &'region mut region::Token<region::Identity<'d>>,
    ) -> app::Drain<'barrier, 'd, ID>
    where
        'd: 'region,
        N: 'session;
}

pub trait Quiescence<'d, ID: Identity = KeyTag<0>>: session::Session<'d, ID> {
    fn quiesce<'a>(
        &self,
        barrier: app::Barrier<'a, 'd, ID>,
        region: &mut region::Token<region::Identity<'d>>,
    ) -> app::Drain<'a, 'd, ID>;
}

impl<'d, ID: Identity, N> Mode<'d, ID, N> for Ready {
    fn select<'session, 'barrier, 'region>(
        _: &'session N,
        barrier: app::Barrier<'barrier, 'd, ID>,
        _: &'region mut region::Token<region::Identity<'d>>,
    ) -> app::Drain<'barrier, 'd, ID>
    where
        'd: 'region,
        N: 'session,
    {
        barrier.ready()
    }
}

impl<'d, ID: Identity, N> Mode<'d, ID, N> for Application
where
    N: Quiescence<'d, ID>,
{
    fn select<'session, 'barrier, 'region>(
        session: &'session N,
        barrier: app::Barrier<'barrier, 'd, ID>,
        region: &'region mut region::Token<region::Identity<'d>>,
    ) -> app::Drain<'barrier, 'd, ID>
    where
        'd: 'region,
        N: 'session,
    {
        session.quiesce(barrier, region)
    }
}