ergot 0.12.0

Eloquence in messaging
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

use crate::logging::info;
use bbq2::{
    prod_cons::stream::StreamConsumer,
    queue::BBQueue,
    traits::{
        bbqhdl::BbqHandle, coordination::Coord, notifier::maitake::MaiNotSpsc, storage::Inline,
    },
};
use core::marker::PhantomData;
use embedded_io_async_0_6::Write;

use crate::interface_manager::{Interface, utils::cobs_stream};

pub struct IoInterface<Q: BbqHandle> {
    _pd: PhantomData<Q>,
}

/// A type alias for the outgoing packet queue typically used by the [`EmbassyInterface`]
pub type Queue<const N: usize, C> = BBQueue<Inline<N>, C, MaiNotSpsc>;
/// A type alias for the InterfaceSink typically used by the [`EmbassyInterface`]
pub type SerialSink<Q> = cobs_stream::Sink<Q>;

/// Interface Implementation
impl<Q: BbqHandle + 'static> Interface for IoInterface<Q> {
    type Sink = SerialSink<Q>;
}

/// Transmitter worker task
///
/// Takes a bbqueue from the NetStack of packets to send. While sending,
/// we will timeout if
pub async fn tx_worker<O: Write, const N: usize, C: Coord>(
    tx: &mut O,
    rx: StreamConsumer<&'static BBQueue<Inline<N>, C, MaiNotSpsc>>,
) -> Result<(), O::Error> {
    info!("Started tx_worker");
    loop {
        let data = rx.wait_read().await;
        let used = tx.write(&data).await?;
        data.release(used);
        if used == 0 {
            return Ok(());
        }
    }
}