Calculate offset using the uncorrected clock Offset is positive if the client is ahead of the server

Calculate the period along with the error in the period estimation When calculating the period, the error in the measurement has a direct relationshi

Creates a new [`watch::Receiver`] connected to the clock distribution watch [`watch::Sender`].

Convert back to an [`Oscillator`] This is helpful for the data collector to capture TSC+System Clock values and convert back into something that is s

Get the current best clock parameters

Getter for `device_path`

* Helper function to calculate a time interval between two timestamps held in a struct timespec. */

Expose a mutable reference to the inner `libc::timex`.

Convenience function to allow for easy instrumenting

Returns the NTP extension Field Type as defined in RFC 5905 A 16-bit value that uniquely identifies the specific extension field and its function #

* Helper function to convert clock status codes into a human readable version. */

* Helper function to convert clock status codes into a human readable version. */

Reads the given `freq` from the underlying `timex`. In struct timex, freq, ppsfreq, and stabil are ppm (parts per million) with a 16-bit fractional p

Returns a reference to all underlying generators This allows inspection of the component generators without modifying them.

Creates an aggregated stream of results from all `SourceIO` component `Receivers`.

Helper to find out if `CLOCK_REALTIME` is now reliable... Any initial states can be considered unreliable, since we have not corrected or been able to

Gets a list of network interface names on the host by inspecting the files under the path "/sys/class/net/".

Gets the round trip delay components for the next NTP event Retrieves forward, backward and server delay values for the next poll time by interpolati

Gets the PCI slot name for a given network interface name. # Arguments `uevent_file_path` - The path of the uevent file where we lookup the `PCI_SLO

Gets the PHC Error Bound sysfs file path given a PCI slot name. # Arguments `pci_slot_name` - The PCI slot name to use for constructing and locating

Gets the PTP device name from the given `uevent_file_path`. # Arguments `uevent_file_path` - The path of the uevent file where we lookup DEVNAME.

Gets the PTP device path for a particular PTP device name. # Arguments `ptp_device_name` - The network interface to lookup the PHC error bound path

Gets the PTP device path for a particular PTP device name. # Arguments `ptp_device_name` - The network interface to lookup the PHC error bound path

Gets the absolute file paths of the uevent files for PTP devices, given the PCI slot name that corresponds to the ENA network interface. File paths a

Gets the uevent file path for a particular network interface.

Handle a clock disruption event Call this function after the system detects a VMClock disruption event. It will go through and clear the state (like

Clear inner state during a disruption event

Clear the internal buffer

Clear the internal buffer

Handles the Simple oscillator command

Handles the Sine oscillator command

Check whether the header is marked with a valid version

Check whether the header is marked with a valid version

Logs into the reproducibility logs that the app has started Can be used to break-up application restarts when scanning logs

private inner function which loops indefinitely. Meant to be wrapped in a timeout Returns the tx tsc, NTP data, and the rx tsc

Returns `true` if the buffer is empty

Returns `true` if this series has no data points

Inspects the given uevent file for a network interface and determines if the corresponding driver is "ena", which is the Amazon elastic network adapte

Returns `true` if the buffer is full

Check whether the header is initialized

Uses instance metadata to determine if instance is bare metal.

Check whether a `ShmHeader` is valid

Check whether a `VMClockShmHeader` is valid

Check whether the header is complete

Check whether the header is complete

Returns the last VMClock read's disruption marker

Check whether the magic number matches the expected one.

Obtain error-bounded timestamps and the `ClockStatus`.

Return the offsets of the time series

Returns true if a PHC source exists (has been created).

Pops a value from the tail Used to remove stale values. Returns `None` if the values are empty

Consuming function call to retrieve timestamp from PTP device. # Errors Returns an error if the PTP ioctl fails.

Adds a new event to the ring buffer Returns true if the event was added, false if it was rejected. The value could be rejected if it is older (via TS

Reads the current set of kernel clock adjustment variables. # Errors `NtpAdjTimeError::Failure` if `ntp_adjtime` returns -1, meaning the system call

Reads a single PHC sample which consists of: - A reference clock timestamp - The corresponding clock error bound for that reference clock timestamp. -

Removes an ntp source from `ntp_sources`

Read a logfile and return all inputs and outputs from the `ClockSyncAlgorithm` # Errors - Returns an error if unable to open the file. - Returns and

Run a whole scenario against a clock sync algorithm. Returns a list of outputs from the inner `feed_link_local` function call

Run a whole scenario against a clock sync algorithm Returns a list of outputs from the feed fn

Creates a `event::Phc` by reading from the PHC `NUM_SAMPLES_PER_POLL` times and retaining the best sample.

Samples the Link local source. When sampling from a NTP source we first collect the current time stamp counter value. We then send a NTP request and

Samples the NTP Source source. When sampling from a NTP source we first collect the current time stamp counter value. We then send a NTP request and

Returns a random value from the truncated distribution. # Panics This function panics if the distribution is re-sampled equal to or more than 1 mill

Outputs the oscillator model to file or stdout

Set up link local source io for testing

Set up link local source io for testing

Test clock disruption polling

Test normal polling

Test basic NTP source functionality

Test polling with varied selected clock source and stratum combinations

Test NTP sources with varied selected clock source combinations

Test startup polling