dope-net 0.39.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
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79

use dope_core::driver::{self, retained::flight, route::Identity};

use crate::{
    link::{
        duplex::sending,
        slot::{transmit::outcome, types},
    },
    wire::{self, send, terminal},
};

fn submit<
    'send,
    'w,
    'd: 'w + 'send,
    ID: Identity + 'w,
    W: wire::Spec + 'w,
    B: send::Payload<'send>,
>(
    slot: &'send mut types::Control<'w, 'd, ID, W>,
    slots: &flight::Slots<'d, ID>,
    driver: &mut driver::Context<'_, 'd>,
    prepare: impl FnOnce(
        send::Context<'send, 'w, ID, W, send::Storage<'send, W::SendStorage<'w>>>,
        terminal::Send<'send, terminal::Error<'w, W>>,
    ) -> terminal::Processed<
        send::Prepared<'send, <W::Send as send::Policy<W>>::Reclaim, B>,
    >,
) -> outcome::Handoff {
    let end = match slot.engine.send(&mut slot.terminal) {
        terminal::Admission::Open(end) => end,
        terminal::Admission::Closed => return outcome::Handoff::blocked(),
    };
    let Some(fd) = slot.engine.establish.fd() else {
        return outcome::Handoff::blocked();
    };
    let Some(submit) = slot
        .engine
        .operations
        .submission(sending::Source::Direct)
        .try_ready()
    else {
        return outcome::Handoff::blocked();
    };
    let context = send::Context::new(&mut slot.wire, send::Storage::new(&mut slot.send));
    let done = prepare(context, end);
    let (ready, captured) = done.into_parts();
    let ready = ready.resolve(captured);
    let submit = submit.submit(fd, slots, driver, slot.key.target(), ready);
    slot.engine.captured(captured);
    outcome::Handoff::from_attempt(submit)
}

/// # Safety
/// Retain the exact immutable input backing at its submitted address until
/// completion or quiescence, including after this call returns.
pub unsafe fn submit_plain<'w, 'd: 'w, ID: Identity + 'w, W: wire::Spec + 'w>(
    slot: &mut types::Control<'w, 'd, ID, W>,
    slots: &flight::Slots<'d, ID>,
    driver: &mut driver::Context<'_, 'd>,
    plain: send::Plain<'_>,
) -> outcome::Handoff {
    submit(slot, slots, driver, |context, end| {
        <W::Send as send::Policy<W>>::prepare::<ID>(context, plain, end)
    })
}

/// # Safety
/// Retain the exact immutable message, iovec and payload graph at submitted
/// addresses until completion or quiescence, including after this call.
pub unsafe fn submit_many<'w, 'd: 'w, ID: Identity + 'w, W: wire::Spec + 'w, const N: usize>(
    slot: &mut types::Control<'w, 'd, ID, W>,
    plain: send::Vectored<'_, N>,
    slots: &flight::Slots<'d, ID>,
    driver: &mut driver::Context<'_, 'd>,
) -> outcome::Handoff {
    submit(slot, slots, driver, |context, end| {
        <W::Send as send::Policy<W>>::prepare_many::<ID, N>(context, plain, end)
    })
}