Method run

clock-bound/src/daemon.rs:175–216

Run the daemon

(mut self: Box<Self>)

                rx,
                clock_disruption_receiver.clone(),
                clock_state_cancellation_token.clone(),
                vmclock_params,
                ClockStatus::Unknown,
            );
            (tx, clock_state)
        };
        let task_tracker = TaskTracker::new();
        let clock_state_handle = ClockStateHandle {
            clock_state: Some(clock_state),
            tx: clock_state_tx,
            cancellation_token: clock_state_cancellation_token,
            task_tracker,
        };

        Self {
            io_front_end,
            clock_sync_algorithm,
            receiver_stream,
            clock_disruption_receiver,
            cancellation_token,
            clock_state_handle,
            dns_message_rx,
            configured_sources,
        }
    }

    /// Install the NTP sources from the configuration file into the daemon.
    ///
    /// Each configured source maps onto a `SourceMutator` action:
    /// - a `server` given as an IP is pinned as a fixed-address NTP source,
    /// - a `server` given as a name is added as a single-host DNS-backed source,
    /// - a `pool` is added as a multi-source DNS-backed pool.
    fn install_configured_sources(
        source_mutator: &mut SourceMutator<'_>,
        configured_sources: &SourcesConfig,
    ) {
        for configured_source in configured_sources.ntp() {
            match configured_source {
                config::NtpSource::Server(Host::Ip(ip)) => {
                    source_mutator.add_ntp_source(SocketAddr::new(*ip, 123), MAX_DISPERSION_GROWTH);
                }
                config::NtpSource::Server(Host::Domain(d)) => {
                    source_mutator.add_domain_host(d.to_string());
                }
                config::NtpSource::Pool(d) => {