dope-manifold 0.43.0

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

use std::task;

use dope_core::driver::schedule::ready;
use dope_net::link::egress::{self, data, metadata::front, reserve::exact};
use o3::base::cell::region;

use crate::{app::dispatch::identity, client::port::receiver::pause::Pause};

/// An inspected head branded by the exact paused source that owns it.
pub(super) struct Head<'source, 'entry, 'e, 'd, S, K, I: identity::Identity> {
    source: &'source Pause<'entry, 'e, 'd, S, I>,
    kind: K,
}

impl<'source, 'entry, 'e, 'd, S: data::raw::Payload<'d>, K, I: identity::Identity>
    Head<'source, 'entry, 'e, 'd, S, K, I>
{
    pub(super) const fn new(source: &'source Pause<'entry, 'e, 'd, S, I>, kind: K) -> Self {
        Self { source, kind }
    }

    pub(super) const fn kind(&self) -> K
    where
        K: Copy,
    {
        self.kind
    }

    pub(super) fn take<'token>(
        self,
        token: &'token mut region::Token<region::Identity<'d>>,
    ) -> Option<front::Front<'entry, 'token, 'e, 'd, S>> {
        if !self.source.is_current() {
            return None;
        }
        self.source.slot().queue().take_front(token)
    }

    pub(super) fn transfer_to<'p, T, const IOV: usize>(
        self,
        token: &'_ mut region::Token<region::Identity<'d>>,
        queue: &egress::Queue<'_, 'p, 'd, IOV, T>,
        target: ready::Target<'d>,
    ) -> Option<task::Poll<Result<(), exact::Failure>>>
    where
        T: data::raw::Payload<'d>,
        for<'queue, 'token> front::Front<'queue, 'token, 'e, 'd, S>: front::Transfer<'d, T>,
    {
        let source = self.take(token)?;
        Some(front::Transfer::transfer_to(source, queue, target))
    }
}