Support bond port settings

The developer wants to use rtnetlink to get and set bond port settings
for a specific bond port, therefore, support parsing the bond port
settings in netlink-route-packet rust crate.

Signed-off-by: Wen Liang <[email protected]>

Author: liangwen12year

src/rtnl/constants.rs

@@ -1032,16 +1032,25 @@ pub const IFLA_BOND_AD_INFO_ACTOR_KEY: u16 = 3;
 pub const IFLA_BOND_AD_INFO_PARTNER_KEY: u16 = 4;
 pub const IFLA_BOND_AD_INFO_PARTNER_MAC: u16 = 5;
 
-// pub const IFLA_BOND_SLAVE_UNSPEC: int = 0;
-// pub const IFLA_BOND_SLAVE_STATE: int = 1;
-// pub const IFLA_BOND_SLAVE_MII_STATUS: int = 2;
-// pub const IFLA_BOND_SLAVE_LINK_FAILURE_COUNT: int = 3;
-// pub const IFLA_BOND_SLAVE_PERM_HWADDR: int = 4;
-// pub const IFLA_BOND_SLAVE_QUEUE_ID: int = 5;
-// pub const IFLA_BOND_SLAVE_AD_AGGREGATOR_ID: int = 6;
-// pub const IFLA_BOND_SLAVE_AD_ACTOR_OPER_PORT_STATE: int = 7;
-// pub const IFLA_BOND_SLAVE_AD_PARTNER_OPER_PORT_STATE: int = 8;
-//
+pub const IFLA_BOND_SLAVE_UNSPEC: u16 = 0;
+pub const IFLA_BOND_SLAVE_STATE: u16 = 1;
+pub const IFLA_BOND_SLAVE_MII_STATUS: u16 = 2;
+pub const IFLA_BOND_SLAVE_LINK_FAILURE_COUNT: u16 = 3;
+pub const IFLA_BOND_SLAVE_PERM_HWADDR: u16 = 4;
+pub const IFLA_BOND_SLAVE_QUEUE_ID: u16 = 5;
+pub const IFLA_BOND_SLAVE_AD_AGGREGATOR_ID: u16 = 6;
+pub const IFLA_BOND_SLAVE_AD_ACTOR_OPER_PORT_STATE: u16 = 7;
+pub const IFLA_BOND_SLAVE_AD_PARTNER_OPER_PORT_STATE: u16 = 8;
+pub const IFLA_BOND_SLAVE_PRIO: u16 = 9;
+
+pub const IFLA_BOND_SLAVE_STATE_ACTIVE: u8 = 0;
+pub const IFLA_BOND_SLAVE_STATE_BACKUP: u8 = 1;
+
+pub const IFLA_BOND_SLAVE_MII_STATUS_UP: u8 = 0;
+pub const IFLA_BOND_SLAVE_MII_STATUS_GOING_DOWN: u8 = 1;
+pub const IFLA_BOND_SLAVE_MII_STATUS_DOWN: u8 = 2;
+pub const IFLA_BOND_SLAVE_MII_STATUS_GOING_BACK: u8 = 3;
+
 // pub const IFLA_VF_INFO_UNSPEC: int = 0;
 // pub const IFLA_VF_INFO: int = 1;
 //

src/rtnl/link/nlas/bond_port.rs

@@ -0,0 +1,179 @@
+// SPDX-License-Identifier: MIT
+use anyhow::Context;
+use byteorder::{ByteOrder, NativeEndian};
+use netlink_packet_utils::{
+    nla::{DefaultNla, Nla, NlaBuffer},
+    parsers::{parse_i32, parse_u16, parse_u32, parse_u8},
+    traits::Parseable,
+    DecodeError,
+};
+
+use crate::constants::*;
+
+#[derive(Debug, Clone, Copy, Eq, PartialEq)]
+#[non_exhaustive]
+pub enum SlaveState {
+    Active,
+    Backup,
+    Other(u8),
+}
+
+impl From<u8> for SlaveState {
+    fn from(value: u8) -> Self {
+        use self::SlaveState::*;
+        match value {
+            IFLA_BOND_SLAVE_STATE_ACTIVE => Active,
+            IFLA_BOND_SLAVE_STATE_BACKUP => Backup,
+            _ => Other(value),
+        }
+    }
+}
+
+impl From<SlaveState> for u8 {
+    fn from(value: SlaveState) -> Self {
+        use self::SlaveState::*;
+        match value {
+            Active => IFLA_BOND_SLAVE_STATE_ACTIVE,
+            Backup => IFLA_BOND_SLAVE_STATE_BACKUP,
+            Other(other) => other,
+        }
+    }
+}
+
+#[derive(Debug, Clone, Copy, Eq, PartialEq)]
+#[non_exhaustive]
+pub enum MiiStatus {
+    Up,
+    GoingDown,
+    Down,
+    GoingBack,
+    Other(u8),
+}
+
+impl From<u8> for MiiStatus {
+    fn from(value: u8) -> Self {
+        use self::MiiStatus::*;
+        match value {
+            IFLA_BOND_SLAVE_MII_STATUS_UP => Up,
+            IFLA_BOND_SLAVE_MII_STATUS_GOING_DOWN => GoingDown,
+            IFLA_BOND_SLAVE_MII_STATUS_DOWN => Down,
+            IFLA_BOND_SLAVE_MII_STATUS_GOING_BACK => GoingBack,
+            _ => Other(value),
+        }
+    }
+}
+
+impl From<MiiStatus> for u8 {
+    fn from(value: MiiStatus) -> Self {
+        use self::MiiStatus::*;
+        match value {
+            Up => IFLA_BOND_SLAVE_MII_STATUS_UP,
+            GoingDown => IFLA_BOND_SLAVE_MII_STATUS_GOING_DOWN,
+            Down => IFLA_BOND_SLAVE_MII_STATUS_DOWN,
+            GoingBack => IFLA_BOND_SLAVE_MII_STATUS_GOING_BACK,
+            Other(other) => other,
+        }
+    }
+}
+
+#[derive(Debug, PartialEq, Eq, Clone)]
+#[non_exhaustive]
+pub enum InfoBondPort {
+    LinkFailureCount(u32),
+    MiiStatus(MiiStatus),
+    PermHwaddr(Vec<u8>),
+    Prio(i32),
+    QueueId(u16),
+    SlaveState(SlaveState),
+    Other(DefaultNla),
+}
+
+impl Nla for InfoBondPort {
+    #[rustfmt::skip]
+    fn value_len(&self) -> usize {
+        use self::InfoBondPort::*;
+        match self {
+            QueueId(_)
+                => 2,
+            LinkFailureCount(_) |
+            Prio(_)
+                => 4,
+            PermHwaddr(ref bytes)
+            => bytes.len(),
+            MiiStatus(_) => 1,
+            SlaveState(_) => 1,
+            Other(nla)
+                => nla.value_len(),
+        }
+    }
+
+    #[rustfmt::skip]
+    fn emit_value(&self, buffer: &mut [u8]) {
+        use self::InfoBondPort::*;
+        match self {
+            QueueId(ref value)
+             => NativeEndian::write_u16(buffer, *value),
+            PermHwaddr(ref bytes)
+             => buffer.copy_from_slice(bytes.as_slice()),
+            Prio(ref value)
+             => NativeEndian::write_i32(buffer, *value),
+            LinkFailureCount(value)
+             => NativeEndian::write_u32(buffer, *value),
+            MiiStatus(state) => buffer[0] = (*state).into(),
+            SlaveState(state) => buffer[0] = (*state).into(),
+            Other(nla)
+             => nla.emit_value(buffer),
+        }
+    }
+
+    fn kind(&self) -> u16 {
+        use self::InfoBondPort::*;
+
+        match self {
+            LinkFailureCount(_) => IFLA_BOND_SLAVE_LINK_FAILURE_COUNT,
+            MiiStatus(_) => IFLA_BOND_SLAVE_MII_STATUS,
+            PermHwaddr(_) => IFLA_BOND_SLAVE_PERM_HWADDR,
+            Prio(_) => IFLA_BOND_SLAVE_PRIO,
+            QueueId(_) => IFLA_BOND_SLAVE_QUEUE_ID,
+            SlaveState(_) => IFLA_BOND_SLAVE_STATE,
+            Other(nla) => nla.kind(),
+        }
+    }
+}
+
+impl<'a, T: AsRef<[u8]> + ?Sized> Parseable<NlaBuffer<&'a T>> for InfoBondPort {
+    fn parse(buf: &NlaBuffer<&'a T>) -> Result<Self, DecodeError> {
+        use self::InfoBondPort::*;
+        let payload = buf.value();
+        Ok(match buf.kind() {
+            IFLA_BOND_SLAVE_LINK_FAILURE_COUNT => {
+                LinkFailureCount(parse_u32(payload).context(
+                    "invalid IFLA_BOND_SLAVE_LINK_FAILURE_COUNT value",
+                )?)
+            }
+            IFLA_BOND_SLAVE_MII_STATUS => MiiStatus(
+                parse_u8(payload)
+                    .context("invalid IFLA_BOND_SLAVE_MII_STATUS value")?
+                    .into(),
+            ),
+            IFLA_BOND_SLAVE_PERM_HWADDR => PermHwaddr(payload.to_vec()),
+            IFLA_BOND_SLAVE_PRIO => Prio(
+                parse_i32(payload)
+                    .context("invalid IFLA_BOND_SLAVE_PRIO value")?,
+            ),
+            IFLA_BOND_SLAVE_QUEUE_ID => QueueId(
+                parse_u16(payload)
+                    .context("invalid IFLA_BOND_SLAVE_QUEUE_ID value")?,
+            ),
+            IFLA_BOND_SLAVE_STATE => SlaveState(
+                parse_u8(payload)
+                    .context("invalid IFLA_BOND_SLAVE_STATE value")?
+                    .into(),
+            ),
+            kind => Other(
+                DefaultNla::parse(buf)
+                    .context(format!("unknown NLA type {kind}"))?,
+            ),
+        })
+    }
+}