Method shutdown_all

clock-bound/src/daemon/io.rs:349–399

Sends shutdown signals to all io tasks. This function sequentially sends `ControlRequest::Shutdown` signals to all io tasks and then waits for all io tasks to exit.

(&mut self)

    /// This function sequentially sends `ControlRequest::Shutdown` signals to all
    /// io tasks and then waits for all io tasks to exit.
    pub async fn shutdown_all(&mut self) {
        info!("Starting shutdown of SourceIO components.");
        // Shutdown link local source
        if let Some(Source {
            state: _,
            ctrl_sender,
        }) = &mut self.link_local
        {
            match ctrl_sender.send(ControlRequest::Shutdown).await {
                Ok(()) => info!("Successfully sent shutdown signal to link local source."),
                Err(e) => warn!(?e, "Failed to send shutdown signal to link local source."),
            }
        }

        // Shutdown PHC source
        if let Some(Source {
            state: _,
            ctrl_sender,
        }) = &mut self.phc
        {
            match ctrl_sender.send(ControlRequest::Shutdown).await {
                Ok(()) => info!("Successfully sent shutdown signal to phc source."),
                Err(e) => warn!(?e, "Failed to send shutdown signal to phc source."),
            }
        }

        // Shutdown vmclock source
        if let Some(Source {
            state: _,
            ctrl_sender,
        }) = &mut self.vmclock
        {
            match ctrl_sender.send(ControlRequest::Shutdown).await {
                Ok(()) => info!("Successfully sent shutdown signal to vmclock source."),
                Err(e) => warn!(?e, "Failed to send shutdown signal to vmclock source."),
            }
        }

        // Shutdown ntp sources
        for ntp_source in self.ntp_sources.values_mut() {
            match ntp_source.ctrl_sender.send(ControlRequest::Shutdown).await {
                Ok(()) => info!("Successfully sent shutdown signal to ntp source."),
                Err(e) => warn!(?e, "Failed to send shutdown signal to ntp source."),
            }
        }

        // Wait for all io tasks to exit
        info!("Waiting for {} io tasks to exit.", self.task_tracker.len());
        self.task_tracker.wait().await;
        info!("All tasks exited. Shutdown of io complete.");
    }
}

/// Communication channels for sending and receiving clock disruption events.