Method create_ntp_source

clock-bound/src/daemon/io.rs:125–158

Initializes the IO task for sampling a specific NTP Server source. # Panics - If not called within the `tokio` runtime. - If socket binding fails.

(&mut self, source: ntp::NTPSourceSender)

    /// - If not called within the `tokio` runtime.
    /// - If socket binding fails.
    pub async fn create_ntp_source(&mut self, source: ntp::NTPSourceSender) {
        let (server_address, event_sender) = source;
        info!(
            "Creating IO source from ntp server at {:#?}.",
            server_address.ip().to_string()
        );

        if !self.ntp_sources.contains_key(&server_address) {
            let (ctrl_sender, ctrl_receiver) = mpsc::channel::<ControlRequest>(1);
            let clock_disruption_receiver = self.clock_disruption_channels.sender.subscribe();

            let socket = UdpSocket::bind(ntp::UNSPECIFIED_SOCKET_ADDRESS)
                .await
                .unwrap();

            let ntp_source = NTPSource::construct(
                socket,
                server_address,
                event_sender,
                ctrl_receiver,
                clock_disruption_receiver,
                self.selected_clock.clone(),
                self.daemon_info.clone(),
            );

            let source = Source {
                state: SourceState::Initialized(ntp_source),
                ctrl_sender,
            };
            self.ntp_sources.insert(server_address, source);
        }

        info!("Source NTP update complete.");
    }

    /// Initializes the IO task for sampling the PHC source.
    ///