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};
11
12use crate::{
13    constants::*,
14    nlas::{self, DefaultNla, NlaBuffer},
15    parsers::{parse_string, parse_u32, parse_u64},
16    traits::Parseable,
17    DecodeError,
18};
19
20#[derive(Debug, PartialEq, Eq, Clone)]
21pub enum Nla {
22    Unspec(Vec<u8>),
23    // FIXME: parse this nla
24    Parms(Vec<u8>),
25    Name(String),
26    Threshold1(u32),
27    Threshold2(u32),
28    Threshold3(u32),
29    Config(Vec<u8>),
30    Stats(Vec<u8>),
31    GcInterval(u64),
32    Other(DefaultNla),
33}
34
35impl nlas::Nla for Nla {
36    #[rustfmt::skip]
37    fn value_len(&self) -> usize {
38        use self::Nla::*;
39        match *self {
40            Unspec(ref bytes) | Parms(ref bytes) | Config(ref bytes) | Stats(ref bytes)=> bytes.len(),
41            // strings: +1 because we need to append a nul byte
42            Name(ref s) => s.len() + 1,
43            Threshold1(_) | Threshold2(_) | Threshold3(_) => 4,
44            GcInterval(_) => 8,
45            Other(ref attr) => attr.value_len(),
46        }
47    }
48
49    fn emit_value(&self, buffer: &mut [u8]) {
50        use self::Nla::*;
51        match *self {
52            Unspec(ref bytes) | Parms(ref bytes) | Config(ref bytes) | Stats(ref bytes) => {
53                buffer.copy_from_slice(bytes.as_slice())
54            }
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) | Threshold2(ref value) | Threshold3(ref value) => {
61                NativeEndian::write_u32(buffer, *value)
62            }
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 => Name(parse_string(payload).context("invalid NDTA_NAME value")?),
92            NDTA_CONFIG => Config(payload.to_vec()),
93            NDTA_STATS => Stats(payload.to_vec()),
94            NDTA_PARMS => Parms(payload.to_vec()),
95            NDTA_GC_INTERVAL => {
96                GcInterval(parse_u64(payload).context("invalid NDTA_GC_INTERVAL value")?)
97            }
98            NDTA_THRESH1 => Threshold1(parse_u32(payload).context("invalid NDTA_THRESH1 value")?),
99            NDTA_THRESH2 => Threshold2(parse_u32(payload).context("invalid NDTA_THRESH2 value")?),
100            NDTA_THRESH3 => Threshold3(parse_u32(payload).context("invalid NDTA_THRESH3 value")?),
101            kind => Other(DefaultNla::parse(buf).context(format!("unknown NLA type {}", kind))?),
102        })
103    }
104}
netlink_packet_route/rtnl/neighbour_table/nlas/mod.rs

netlink_packet_route/rtnl/neighbour_table/nlas/
mod.rs
