netlink_packet_route/rule/
message.rs

1// SPDX-License-Identifier: MIT
2
3use super::{RuleAttribute, RuleError, RuleHeader, RuleMessageBuffer};
4use netlink_packet_utils::traits::{Emitable, Parseable};
5
6#[derive(Debug, PartialEq, Eq, Clone, Default)]
7#[non_exhaustive]
8pub struct RuleMessage {
9    pub header: RuleHeader,
10    pub attributes: Vec<RuleAttribute>,
11}
12
13impl Emitable for RuleMessage {
14    fn buffer_len(&self) -> usize {
15        self.header.buffer_len() + self.attributes.as_slice().buffer_len()
16    }
17
18    fn emit(&self, buffer: &mut [u8]) {
19        self.header.emit(buffer);
20        self.attributes.as_slice().emit(&mut buffer[self.header.buffer_len()..]);
21    }
22}
23
24impl<'a, T: AsRef<[u8]> + 'a> Parseable<RuleMessageBuffer<&'a T>> for RuleMessage {
25    type Error = RuleError;
26    fn parse(buf: &RuleMessageBuffer<&'a T>) -> Result<Self, RuleError> {
27        // unwrap: RuleHeader never fails to parse.
28        let header = RuleHeader::parse(buf).unwrap();
29        let attributes = Vec::<RuleAttribute>::parse(buf)?;
30        Ok(RuleMessage { header, attributes })
31    }
32}
33
34impl<'a, T: AsRef<[u8]> + 'a> Parseable<RuleMessageBuffer<&'a T>> for Vec<RuleAttribute> {
35    type Error = RuleError;
36    fn parse(buf: &RuleMessageBuffer<&'a T>) -> Result<Self, RuleError> {
37        let mut attributes = vec![];
38        for nla_buf in buf.attributes() {
39            attributes.push(RuleAttribute::parse(&nla_buf?)?);
40        }
41        Ok(attributes)
42    }
43}