ntpd 1.7.2

Full-featured implementation of NTP with NTS support
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

use std::{net::IpAddr, sync::Arc};

use timestamped_socket::interface::{ChangeDetector, interfaces};
use tokio::sync::watch;

pub fn spawn() -> std::io::Result<watch::Receiver<Arc<[IpAddr]>>> {
    let mut change_listener = ChangeDetector::new()?;
    let local_ips: Arc<[IpAddr]> = interfaces()?
        .iter()
        .flat_map(|(_, interface)| interface.ips())
        .collect();

    let (writer, reader) = watch::channel(local_ips);

    tokio::spawn(async move {
        loop {
            change_listener.wait_for_change().await;
            match interfaces() {
                Ok(interfaces) => {
                    let _ = writer.send(
                        interfaces
                            .iter()
                            .flat_map(|(_, interface)| interface.ips())
                            .collect(),
                    );
                }
                Err(e) => {
                    tracing::warn!(
                        "Could not get new list of which ip addresses the interfaces in the system have: {}",
                        e
                    );
                }
            }
        }
    });

    Ok(reader)
}