Method construct

clock-bound/src/daemon/io/phc.rs:184–203

Constructs a new `Phc` IO source instance using the given parameters. This implementation performs autoconfiguration to determine the PHC device that should be used for obtaining reference clock timestamps and the corresponding clock error bound for those timestamps.

(
        event_sender: async_ring_buffer::Sender<event::Phc>,
        ctrl_receiver: mpsc::Receiver<ControlRequest>,
        clock_disruption_receiver: watch::Receiver<ClockDisruptionEvent>,
    )

    /// This implementation performs autoconfiguration to determine
    /// the PHC device that should be used for obtaining reference clock
    /// timestamps and the corresponding clock error bound for those timestamps.
    pub async fn construct(
        event_sender: async_ring_buffer::Sender<event::Phc>,
        ctrl_receiver: mpsc::Receiver<ControlRequest>,
        clock_disruption_receiver: watch::Receiver<ClockDisruptionEvent>,
    ) -> Result<Self, PhcError> {
        let (phc_reader, phc_clock_error_bound_reader, device_path) =
            Self::autoconfigure_phc_readers().await?;
        let mut phc_interval = interval(PHC_SOURCE_INTERVAL_DURATION);
        phc_interval.set_missed_tick_behavior(MissedTickBehavior::Delay);

        Ok(Phc {
            event_sender,
            ctrl_receiver,
            clock_disruption_receiver,
            interval: phc_interval,
            reader: phc_reader,
            clock_error_bound_reader: phc_clock_error_bound_reader,
            device_path,
        })
    }

    /// Getter for `device_path`