aic8800 0.3.0

OS-independent AIC8800 Wi-Fi driver core
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

//! Single-owner transmit progression.

use alloc::{collections::VecDeque, vec::Vec};

use crate::{TxToken, protocol::ethernet_tx_frame};

pub(crate) const TX_CAPACITY: usize = 128;

pub(crate) struct PendingTx {
    pub token: TxToken,
    pub frame: Vec<u8>,
}

pub(crate) struct TxState {
    queue: VecDeque<PendingTx>,
}

impl TxState {
    pub(crate) const fn new() -> Self {
        Self {
            queue: VecDeque::new(),
        }
    }

    pub(crate) fn enqueue(&mut self, token: TxToken, frame: Vec<u8>) -> Result<(), Vec<u8>> {
        if self.queue.len() >= TX_CAPACITY {
            return Err(frame);
        }
        self.queue.push_back(PendingTx { token, frame });
        Ok(())
    }

    pub(crate) fn take_wire_frame(
        &mut self,
        interface_index: u8,
        station_index: u8,
        v3: bool,
    ) -> Option<Result<(TxToken, Vec<u8>), TxToken>> {
        let pending = self.queue.pop_front()?;
        Some(
            ethernet_tx_frame(&pending.frame, interface_index, station_index, v3)
                .map(|frame| (pending.token, frame))
                .map_err(|_| pending.token),
        )
    }

    pub(crate) fn drain_tokens(&mut self) -> impl Iterator<Item = TxToken> + '_ {
        self.queue.drain(..).map(|pending| pending.token)
    }
}