netlink_packet_route/tc/stats/
xstats.rs

Help
1// SPDX-License-Identifier: MIT
2
3use crate::tc::{TcError, TcFqCodelXstats, TcQdiscFqCodel};
4use netlink_packet_utils::nla::NlaBuffer;
5use netlink_packet_utils::traits::{Emitable, Parseable, ParseableParametrized};
6
7#[derive(Debug, PartialEq, Eq, Clone)]
8#[non_exhaustive]
9pub enum TcXstats {
10    FqCodel(TcFqCodelXstats),
11    Other(Vec<u8>),
12}
13
14impl Emitable for TcXstats {
15    fn buffer_len(&self) -> usize {
16        match self {
17            Self::FqCodel(v) => v.buffer_len(),
18            Self::Other(v) => v.len(),
19        }
20    }
21
22    fn emit(&self, buffer: &mut [u8]) {
23        match self {
24            Self::FqCodel(v) => v.emit(buffer),
25            Self::Other(v) => buffer.copy_from_slice(v.as_slice()),
26        }
27    }
28}
29
30impl<'a, T> ParseableParametrized<NlaBuffer<&'a T>, &str> for TcXstats
31where
32    T: AsRef<[u8]> + ?Sized,
33{
34    type Error = TcError;
35    fn parse_with_param(buf: &NlaBuffer<&'a T>, kind: &str) -> Result<TcXstats, Self::Error> {
36        Ok(match kind {
37            TcQdiscFqCodel::KIND => TcXstats::FqCodel(TcFqCodelXstats::parse(buf.value())?),
38            _ => TcXstats::Other(buf.value().to_vec()),
39        })
40    }
41}
netlink_packet_route/tc/stats/xstats.rs

netlink_packet_route/tc/stats/
xstats.rs
