Method create_link_local

clock-bound/src/daemon/io.rs:90–118

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

(&mut self, event_sender: async_ring_buffer::Sender<event::Ntp>)

    /// - If not called within the `tokio` runtime.
    /// - If socket binding fails.
    pub async fn create_link_local(&mut self, event_sender: async_ring_buffer::Sender<event::Ntp>) {
        info!("Creating link local source.");

        debug!(?self.link_local, "Current source entry status");
        if self.link_local.is_none() {
            self.link_local = {
                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 link_local = LinkLocal::construct(
                    socket,
                    event_sender,
                    ctrl_receiver,
                    clock_disruption_receiver,
                    self.selected_clock.clone(),
                );
                Some(Source {
                    state: SourceState::Initialized(link_local),
                    ctrl_sender,
                })
            };
        }

        info!("Source link local update complete.");
    }

    /// Initializes the IO task for sampling a specific NTP Server source.
    ///