netlink_packet_route/rule/
message.rs

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

netlink_packet_route/rule/
message.rs
