Struct NodeStack 

pub struct NodeStack<'a, R: Radio> {
    pub host: Host<MacHandle<'a, TokioPlatform<R, TokioFileCounterStore, TokioFileKeyValueStore>, IDENTITIES, PEERS, CHANNELS, ACKS, TX, FRAME, DUP>>,
    pub node: LocalNode<MacHandle<'a, TokioPlatform<R, TokioFileCounterStore, TokioFileKeyValueStore>, IDENTITIES, PEERS, CHANNELS, ACKS, TX, FRAME, DUP>>,
    pub handle: MacHandle<'a, TokioPlatform<R, TokioFileCounterStore, TokioFileKeyValueStore>, IDENTITIES, PEERS, CHANNELS, ACKS, TX, FRAME, DUP>,
    started: Instant,
}

The tool as a node: a host MAC over the borrowed radio, one local node standing for the administrator identity, and the pump that keeps both moving.

Fields

host: Host<MacHandle<'a, TokioPlatform<R, TokioFileCounterStore, TokioFileKeyValueStore>, IDENTITIES, PEERS, CHANNELS, ACKS, TX, FRAME, DUP>>

node: LocalNode<MacHandle<'a, TokioPlatform<R, TokioFileCounterStore, TokioFileKeyValueStore>, IDENTITIES, PEERS, CHANNELS, ACKS, TX, FRAME, DUP>>

handle: MacHandle<'a, TokioPlatform<R, TokioFileCounterStore, TokioFileKeyValueStore>, IDENTITIES, PEERS, CHANNELS, ACKS, TX, FRAME, DUP>

started: Instant

Implementations

impl<'a, R: Radio> NodeStack<'a, R>

where R::Error: Debug,

pub async fn build( mac: &'a AsyncRefCell<Mac<TokioPlatform<R, TokioFileCounterStore, TokioFileKeyValueStore>, IDENTITIES, PEERS, CHANNELS, ACKS, TX, FRAME, DUP>>, identity: SoftwareIdentity, ) -> Result<(Self, PublicKey)>

Register identity on the borrowed MAC and stand a node up on it, returning the stack and the administrator’s public key.

pub fn started(&self) -> Instant

When this stack came up. The exchange engine’s deadlines are expressed against Self::now_ms, which counts from here.

pub fn now_ms(&self) -> u64

pub async fn pump_until(&mut self, deadline: Instant) -> Result<()>

Drive the MAC until it has nothing to do or deadline arrives.

A quiet radio produces no MAC wake, so the timeouts that retire an unanswered acknowledgment need their own nudge afterwards.

pub async fn exchange( &mut self, manager: &mut NodeManager<MacHandle<'a, TokioPlatform<R, TokioFileCounterStore, TokioFileKeyValueStore>, IDENTITIES, PEERS, CHANNELS, ACKS, TX, FRAME, DUP>>, request: &[u8], give_up: Instant, ) -> Result<Outcome>

Carry one exchange to its end, pumping the host in between, giving up at give_up.