rtnetlink/link/
property_del.rs1use futures_util::stream::StreamExt;
4use netlink_packet_core::{
5 NetlinkMessage, NetlinkPayload, NLM_F_ACK, NLM_F_REQUEST,
6};
7use netlink_packet_route::{
8 link::{LinkAttribute, LinkMessage, Prop},
9 RouteNetlinkMessage,
10};
11
12use crate::{Error, Handle};
13
14pub struct LinkDelPropRequest {
15 handle: Handle,
16 message: LinkMessage,
17}
18
19impl LinkDelPropRequest {
20 pub(crate) fn new(handle: Handle, index: u32) -> Self {
21 let mut message = LinkMessage::default();
22 message.header.index = index;
23 LinkDelPropRequest { handle, message }
24 }
25
26 pub async fn execute(self) -> Result<(), Error> {
28 let LinkDelPropRequest {
29 mut handle,
30 message,
31 } = self;
32 let mut req =
33 NetlinkMessage::from(RouteNetlinkMessage::DelLinkProp(message));
34 req.header.flags = NLM_F_REQUEST | NLM_F_ACK;
35
36 let mut response = handle.request(req)?;
37 while let Some(message) = response.next().await {
38 if let NetlinkPayload::Error(err) = message.payload {
39 return Err(Error::NetlinkError(err));
40 }
41 }
42 Ok(())
43 }
44
45 pub fn message_mut(&mut self) -> &mut LinkMessage {
47 &mut self.message
48 }
49
50 pub fn alt_ifname(mut self, alt_ifnames: &[&str]) -> Self {
53 let mut props = Vec::new();
54 for alt_ifname in alt_ifnames {
55 props.push(Prop::AltIfName(alt_ifname.to_string()));
56 }
57
58 self.message.attributes.push(LinkAttribute::PropList(props));
59 self
60 }
61}