netlink_packet_route/rtnl/neighbour_table/nlas/
mod.rs

1// SPDX-License-Identifier: MIT
2
3mod config;
4pub use config::*;
5
6mod stats;
7pub use stats::*;
8
9use anyhow::Context;
10use byteorder::{ByteOrder, NativeEndian};
11use netlink_packet_utils::{
12    nla::{self, DefaultNla, NlaBuffer},
13    parsers::{parse_string, parse_u32, parse_u64},
14    traits::Parseable,
15    DecodeError,
16};
17
18use crate::constants::*;
19
20#[derive(Debug, PartialEq, Eq, Clone)]
21#[non_exhaustive]
22pub enum Nla {
23    Unspec(Vec<u8>),
24    // FIXME: parse this nla
25    Parms(Vec<u8>),
26    Name(String),
27    Threshold1(u32),
28    Threshold2(u32),
29    Threshold3(u32),
30    Config(Vec<u8>),
31    Stats(Vec<u8>),
32    GcInterval(u64),
33    Other(DefaultNla),
34}
35
36impl nla::Nla for Nla {
37    #[rustfmt::skip]
38    fn value_len(&self) -> usize {
39        use self::Nla::*;
40        match *self {
41            Unspec(ref bytes) | Parms(ref bytes) | Config(ref bytes) | Stats(ref bytes)=> bytes.len(),
42            // strings: +1 because we need to append a nul byte
43            Name(ref s) => s.len() + 1,
44            Threshold1(_) | Threshold2(_) | Threshold3(_) => 4,
45            GcInterval(_) => 8,
46            Other(ref attr) => attr.value_len(),
47        }
48    }
49
50    fn emit_value(&self, buffer: &mut [u8]) {
51        use self::Nla::*;
52        match *self {
53            Unspec(ref bytes) | Parms(ref bytes) | Config(ref bytes)
54            | Stats(ref bytes) => buffer.copy_from_slice(bytes.as_slice()),
55            Name(ref string) => {
56                buffer[..string.len()].copy_from_slice(string.as_bytes());
57                buffer[string.len()] = 0;
58            }
59            GcInterval(ref value) => NativeEndian::write_u64(buffer, *value),
60            Threshold1(ref value)
61            | Threshold2(ref value)
62            | Threshold3(ref value) => NativeEndian::write_u32(buffer, *value),
63            Other(ref attr) => attr.emit_value(buffer),
64        }
65    }
66
67    fn kind(&self) -> u16 {
68        use self::Nla::*;
69        match *self {
70            Unspec(_) => NDTA_UNSPEC,
71            Name(_) => NDTA_NAME,
72            Config(_) => NDTA_CONFIG,
73            Stats(_) => NDTA_STATS,
74            Parms(_) => NDTA_PARMS,
75            GcInterval(_) => NDTA_GC_INTERVAL,
76            Threshold1(_) => NDTA_THRESH1,
77            Threshold2(_) => NDTA_THRESH2,
78            Threshold3(_) => NDTA_THRESH3,
79            Other(ref attr) => attr.kind(),
80        }
81    }
82}
83
84impl<'a, T: AsRef<[u8]> + ?Sized> Parseable<NlaBuffer<&'a T>> for Nla {
85    fn parse(buf: &NlaBuffer<&'a T>) -> Result<Self, DecodeError> {
86        use self::Nla::*;
87
88        let payload = buf.value();
89        Ok(match buf.kind() {
90            NDTA_UNSPEC => Unspec(payload.to_vec()),
91            NDTA_NAME => {
92                Name(parse_string(payload).context("invalid NDTA_NAME value")?)
93            }
94            NDTA_CONFIG => Config(payload.to_vec()),
95            NDTA_STATS => Stats(payload.to_vec()),
96            NDTA_PARMS => Parms(payload.to_vec()),
97            NDTA_GC_INTERVAL => GcInterval(
98                parse_u64(payload).context("invalid NDTA_GC_INTERVAL value")?,
99            ),
100            NDTA_THRESH1 => Threshold1(
101                parse_u32(payload).context("invalid NDTA_THRESH1 value")?,
102            ),
103            NDTA_THRESH2 => Threshold2(
104                parse_u32(payload).context("invalid NDTA_THRESH2 value")?,
105            ),
106            NDTA_THRESH3 => Threshold3(
107                parse_u32(payload).context("invalid NDTA_THRESH3 value")?,
108            ),
109            kind => Other(
110                DefaultNla::parse(buf)
111                    .context(format!("unknown NLA type {kind}"))?,
112            ),
113        })
114    }
115}
netlink_packet_route/rtnl/neighbour_table/nlas/mod.rs

netlink_packet_route/rtnl/neighbour_table/nlas/
mod.rs
