dope-manifold 0.22.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

use std::mem;

use dope_core::driver::route::{Identity, KeyTag};

use crate::{
    client::attempt,
    service::pool::{self, dials},
};

pub(in crate::service::pool) enum Connection<'a, 'q, 'h, 'd, ID: Identity> {
    Pending(Connect<'a, 'q, 'h, 'd, ID>),
    Stale,
}

/// Dropping admission leaves the submitted dial owned by its transport finalizer.
pub(in crate::service::pool) struct Connect<'a, 'q, 'h, 'd, ID: Identity> {
    pub(super) dial: &'a dials::Dial<'q, 'h, 'd, ID>,
    pub(super) target: pool::Target<'h>,
}

impl<'h, ID: Identity> Connect<'_, '_, 'h, '_, ID> {
    pub(in crate::service::pool) const fn target(&self) -> pool::Target<'h> {
        self.target
    }

    pub(in crate::service::pool) fn commit(self, target: pool::Target<'h>) {
        self.dial.state.set(dials::State::Connected(target));
    }
}

const _: () = {
    assert!(
        mem::size_of::<Connect<'static, 'static, 'static, 'static, KeyTag<0>>>()
            == mem::size_of::<(
                &dials::Dial<'static, 'static, 'static, KeyTag<0>>,
                pool::Target<'static>
            )>()
    );
    assert!(
        mem::size_of::<Connect<'static, 'static, 'static, 'static, KeyTag<0>>>()
            <= mem::size_of::<(&mut (), attempt::Slot, pool::Target<'static>)>()
    );
};