ts_netstack_smoltcp_core 0.3.3

command-channel-based userspace netstack built on smoltcp (core functionality)
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63

use core::net::IpAddr;

use crate::{Error, HasChannel, Netstack, Response, command::stack_control};

/// Extension methods for control channels ([`HasChannel`]) supporting ergonomic operations
/// around [`stack_control::Command`]s.
pub trait NetstackControl: HasChannel {
    /// Set the IPs for the netstack interface.
    ///
    /// The netstack must have space to store all the provided IPs -- this is controlled
    /// by `smoltcp`'s `iface-max-addr-count-*` features. You must configure this as the end
    /// user because it is global to all usages of this version of `smoltcp`.
    fn set_ips_blocking(&self, ips: impl IntoIterator<Item = IpAddr>) -> Result<(), Error> {
        self.request_blocking(
            None,
            stack_control::Command::SetIps {
                new_ips: ips.into_iter().collect(),
            },
        )?
        .to_ok()
    }

    /// Set the IPs for the netstack interface.
    ///
    /// The netstack must have space to store all the provided IPs -- this is controlled
    /// by `smoltcp`'s `iface-max-addr-count-*` features. You must configure this as the end
    /// user because it is global to all usages of this version of `smoltcp`.
    fn set_ips(
        &self,
        ips: impl IntoIterator<Item = IpAddr>,
    ) -> impl Future<Output = Result<(), Error>> + Send {
        let channel = self.command_channel();
        let new_ips = ips.into_iter().collect();

        async move {
            crate::request(channel, None, stack_control::Command::SetIps { new_ips })
                .await?
                .to_ok()
        }
    }
}

impl<T> NetstackControl for T where T: HasChannel {}

impl Netstack {
    #[tracing::instrument(skip(self), level = "debug")]
    pub(crate) fn process_stack_control(&mut self, command: stack_control::Command) -> Response {
        match command {
            stack_control::Command::SetIps { new_ips } => {
                if !self.direct_set_ips(new_ips.iter().copied()) {
                    tracing::error!(
                        ?new_ips,
                        "not enough address storage space configured in smoltcp"
                    );

                    return Error::buffer_full().into();
                }

                Response::Ok
            }
        }
    }
}