Method create_phc

clock-bound/src/daemon/io.rs:164–186

Initializes the IO task for sampling the PHC source. # Panics - If not called within the `tokio` runtime.

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

    /// # Panics
    /// - If not called within the `tokio` runtime.
    pub async fn create_phc(&mut self, event_sender: async_ring_buffer::Sender<event::Phc>) {
        info!("Creating PHC source.");

        debug!(?self.phc, "Current PHC source entry status");
        if self.phc.is_none() {
            self.phc = {
                let (ctrl_sender, ctrl_receiver) = mpsc::channel::<ControlRequest>(1);
                let clock_disruption_receiver = self.clock_disruption_channels.sender.subscribe();
                match Phc::construct(event_sender, ctrl_receiver, clock_disruption_receiver).await {
                    Ok(phc) => Some(Source {
                        state: SourceState::Initialized(phc),
                        ctrl_sender,
                    }),
                    Err(e) => {
                        warn!("{}", e);
                        None
                    }
                }
            };
        }

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

    pub fn phc(&self) -> Option<&Phc> {
        self.phc.as_ref().and_then(|s| match &s.state {