dope-net 0.15.1

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
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65

use dope_core::driver::route;
use o3::cell::region;

use crate::link::egress::{self, data, queue::flight};

pub(in crate::link) struct Transfer<'a, 'queue, 'd, const IOV: usize, B> {
    queue: &'a mut egress::Queue<'queue, 'd, IOV, B>,
}

impl<'a, 'queue, 'd, const IOV: usize, B: data::Payload<'d>> Transfer<'a, 'queue, 'd, IOV, B> {
    pub(super) fn new(queue: &'a mut egress::Queue<'queue, 'd, IOV, B>) -> Self {
        Self { queue }
    }

    pub(in crate::link) fn complete(
        &mut self,
        token: &mut region::Token<'d>,
        target: route::Token,
        bytes: usize,
    ) -> bool {
        let Some(released) = self.queue.flight.complete(target, bytes) else {
            return false;
        };
        let acknowledged = self.settle(token, released);
        debug_assert!(acknowledged, "a completed flight is an ACK prefix");
        acknowledged
    }

    pub(in crate::link) fn abort(&mut self, target: route::Token) -> bool {
        if !self.queue.flight.abort(target) {
            return false;
        }
        self.queue.counters.set_partial(0);
        true
    }

    pub(in crate::link) fn settle(
        &mut self,
        token: &mut region::Token<'d>,
        released: flight::Released<IOV>,
    ) -> bool {
        self.queue.ack(token, released)
    }

    pub(in crate::link) fn settle_submitted(
        &mut self,
        token: &mut region::Token<'d>,
        released: flight::Released<IOV>,
        bytes: usize,
    ) -> bool {
        self.settle(token, released) && self.record_submitted(bytes)
    }

    fn record_submitted(&self, bytes: usize) -> bool {
        let Some(total) = self.queue.counters.submitted().checked_add(bytes) else {
            return false;
        };
        self.queue.counters.set_submitted(total);
        true
    }

    pub(in crate::link) fn take_submitted(&self) -> usize {
        self.queue.counters.take_submitted()
    }
}