rtnetlink/traffic_control/
del_qdisc.rs

1// SPDX-License-Identifier: MIT
2
3use futures::StreamExt;
4use netlink_packet_core::{NetlinkMessage, NLM_F_ACK, NLM_F_REQUEST};
5use netlink_packet_route::{RtnlMessage, TcMessage};
6
7use crate::{try_nl, Error, Handle};
8
9pub struct QDiscDelRequest {
10    handle: Handle,
11    message: TcMessage,
12}
13
14impl QDiscDelRequest {
15    pub(crate) fn new(handle: Handle, message: TcMessage) -> Self {
16        QDiscDelRequest { handle, message }
17    }
18
19    // Execute the request
20    pub async fn execute(self) -> Result<(), Error> {
21        let QDiscDelRequest {
22            mut handle,
23            message,
24        } = self;
25
26        let mut req =
27            NetlinkMessage::from(RtnlMessage::DelQueueDiscipline(message));
28        req.header.flags = NLM_F_REQUEST | NLM_F_ACK;
29
30        let mut response = handle.request(req)?;
31        while let Some(message) = response.next().await {
32            try_nl!(message)
33        }
34        Ok(())
35    }
36
37    /// Return a mutable reference to the request
38    pub fn message_mut(&mut self) -> &mut TcMessage {
39        &mut self.message
40    }
41}
rtnetlink/traffic_control/del_qdisc.rs

rtnetlink/traffic_control/
del_qdisc.rs
