MCPcopy Create free account

hub / github.com/aws/clock-bound / functions

Functions1,214 in github.com/aws/clock-bound

⨍ Functions 1,214◇ Types & classes 277
↓ 3 callersFunctionremove_file_or_directory
Helper function to remove files created during unit tests.
clock-bound/src/vmclock/shm_writer.rs:330
↓ 3 callersMethodsample
Reads the VMClock shared memory page and returns the current clock state.
clock-bound/src/daemon/io/vmclock.rs:115
↓ 3 callersMethodsnapshot
Returns a snapshot of the shared memory segment last populated by the ClockBound daemon.
clock-bound/src/client.rs:165
↓ 3 callersMethodsocket_address
(&self)
clock-bound/src/daemon/clock_sync_algorithm/source/ntp_source.rs:44
↓ 3 callersMethodstep_clock
(&self, _phase_correction: Duration)
clock-bound/src/daemon/clock_state/clock_adjust/ntp_adjtime.rs:44
↓ 3 callersFunctiontester_event_from_cb_ntp
(event: &event::Ntp, source_id: String)
clock-bound-ff-tester/src/repro.rs:99
↓ 3 callersMethodto_initial_snapshot_retrieved
( &self, ntp_adjtime: &impl NtpAdjTimeExt, )
clock-bound/src/daemon/clock_state/clock_adjust/state_machine.rs:206
↓ 3 callersMethodto_phase_correct_halted
( &self, ntp_adjtime: &impl NtpAdjTimeExt, )
clock-bound/src/daemon/clock_state/clock_adjust/state_machine.rs:265
↓ 3 callersMethodto_snapshot_retrieved
( &self, ntp_adjtime: &impl NtpAdjTimeExt, )
clock-bound/src/daemon/clock_state/clock_adjust/state_machine.rs:293
↓ 3 callersMethodwrite_shm1
Write out to the ClockBound daemon shared memory segment shm1. Writes the latest supported layout version (V3) of the shared memory segment.
clock-bound/src/daemon/clock_state/clock_state_writer.rs:223
↓ 3 callersFunctionwrite_vmclock_content
(file: &mut File, vmclock_content: &VMClockContent)
clock-bound/src/client.rs:390
↓ 2 callersMethodabsolute_time_indexes
Get the absolute time of a time series of durations Useful for ad-hoc conversion between a generic time series of durations and a series with a known
clock-bound-ff-tester/src/time/series.rs:85
↓ 2 callersMethodapproximate
(&self, x: Self::X)
clock-bound-ff-tester/src/simulation/interpolation.rs:76
↓ 2 callersMethodas_seconds_trunc
Returns the total number of seconds, truncated
clock-bound/src/daemon/time/inner.rs:296
↓ 2 callersMethodcalculate_clock_error_bound
Calculate the clock error bound of this event at the time of the event This is different from the clock error bound that would be reported to a user
clock-bound/src/daemon/event/ntp.rs:173
↓ 2 callersFunctioncalculate_frequency_correction
( clock_params: &ClockParameters, old_snapshot: &ClockSnapshot, new_snapshot: &ClockSnapshot, )
clock-bound/src/daemon/clock_state/clock_adjust/state_machine.rs:390
↓ 2 callersMethodcalculate_ntp_event_timestamps
Calculate the NTP event timestamps driven by the local oscillator timestamp - `oscillator_estimated_send_time` is the estimated time after the start
clock-bound-ff-tester/src/simulation/ntp/round_trip_delays.rs:108
↓ 2 callersMethodcalculate_ntp_event_timestamps
Return all of the NTP timestamps for an event given an oscillator model Useful if not using this struct as a generator, but as a primitive building b
clock-bound-ff-tester/src/simulation/ntp/perfect.rs:110
↓ 2 callersMethodcalculate_ntp_event_timestamps
Calculates all timestamps for an NTP event based on the current state Returns the client send/receive times and server receive/send times for the nex
clock-bound-ff-tester/src/simulation/ntp/series.rs:233
↓ 2 callersMethodcalculate_period
Calculate a period by using 2 NTP events using midpoints NTP traffic is characterized in ClockBound with each exchange having a - `tsc_pre`: The TSC
clock-bound/src/daemon/event/ntp.rs:88
↓ 2 callersMethodclear
(&self)
clock-bound/src/daemon/io/ntp/socket_ext.rs:13
↓ 2 callersFunctionclock_freq_ghz
()
clock-bound-ff-tester/src/simulation/ntp/series.rs:550
↓ 2 callersMethodcompare_to_clock_bound_client_clock
( &self, clock: &mut T, )
test/clock-bound-phc-offset/src/phc.rs:184
↓ 2 callersMethodcompute_bound_at_tsc
(&self, now_tsc: u64)
clock-bound/src/shm.rs:719
↓ 2 callersFunctioncreate_link_local
()
clock-bound/src/daemon/io/link_local.rs:288
↓ 2 callersFunctioncreate_noise_model
Creates a noise model if noise is enabled
clock-bound-ff-tester/src/bin/oscillator_generator.rs:163
↓ 2 callersFunctioncreate_ntp_event
(pre: TscCount, post: TscCount, server_time: Instant)
clock-bound/src/daemon/event/ntp.rs:449
↓ 2 callersFunctioncreate_ntp_event_with_error
( pre: TscCount, post: TscCount, server_time: Instant, server_time_error: Dura
clock-bound/src/daemon/event/ntp.rs:701
↓ 2 callersFunctioncreate_ntp_generator
( forward_network: Box<dyn DelayRng>, backward_network: Box<dyn DelayRng>, server_delay: Box<dyn D
clock-bound-ff-tester/src/bin/scenario_generator.rs:308
↓ 2 callersMethodcreate_ntp_source
Initializes the IO task for sampling a specific NTP Server source. # Panics - If not called within the `tokio` runtime. - If socket binding fails.
clock-bound/src/daemon/io.rs:125
↓ 2 callersMethodcreate_phc
Initializes the IO task for sampling the PHC source. # Panics - If not called within the `tokio` runtime.
clock-bound/src/daemon/io.rs:164
↓ 2 callersFunctioncreate_phc_event
(pre: TscCount, post: TscCount, server_time: Instant)
clock-bound/src/daemon/event/phc.rs:266
↓ 2 callersFunctioncreate_phc_event_with_error
( pre: TscCount, post: TscCount, server_time: Instant, error: Duration, )
clock-bound/src/daemon/event/phc.rs:437
↓ 2 callersFunctioncreate_sine_oscillator_file
Creates a sine oscillator file for testing with parameters similar to the example output
clock-bound-ff-tester/src/bin/scenario_generator.rs:362
↓ 2 callersFunctiondebug_femtos
print in <seconds>.<millis>_<micros>_<nanos> format.
clock-bound/src/daemon/time/inner.rs:659
↓ 2 callersMethoddetermine_clock_error_bound_v2_status
Determines the `ClockStatus` to write to the SHM for `ClockErrorBoundV2`, which depends on the system clock underneath the hood.
clock-bound/src/daemon/clock_state.rs:181
↓ 2 callersMethodemit_bytes
Serializes the extension field to bytes in network byte order # Arguments `buffer` - Mutable byte slice to write the extension data to # Panics Pani
clock-bound/src/daemon/io/ntp/packet/extension.rs:91
↓ 2 callersMethodexpected_offset_change_due_to_phase_correction_at
(&self, time: Instant)
test/clock-bound-adjust-clock-test/src/adjust_clock_test.rs:175
↓ 2 callersMethodexpected_offset_change_due_to_skew_at
(&self, time: Instant)
test/clock-bound-adjust-clock-test/src/adjust_clock_test.rs:232
↓ 2 callersMethodfeed_phc
(&mut self, event: &Event)
clock-bound-ff-tester/src/sim_phc.rs:52
↓ 2 callersFunctionformat_err_kind
* Helper function to convert clockbound error kind codes into a human readable version. */
examples/client/c/src/clockbound_loop_forever.c:33
↓ 2 callersFunctionformat_err_kind
* Helper function to convert clockbound error kind codes into a human readable version. */
examples/client/c/src/clockbound_now.c:34
↓ 2 callersMethodgenerate_round_trip_delays
( &self, rng: &mut rand_chacha::ChaCha12Rng, )
clock-bound-ff-tester/src/simulation/ntp/round_trip_delays.rs:33
↓ 2 callersFunctionget_network_interfaces
Gets a list of network interface names on the host by inspecting the files under the path "/sys/class/net/".
clock-bound/src/daemon/io/phc.rs:635
↓ 2 callersMethodget_offset_from_utc_clock
( &self, clock: &T, )
test/clock-bound-phc-offset/src/phc.rs:139
↓ 2 callersFunctionget_phc_clock_error_bound_sysfs_path
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
clock-bound/src/daemon/io/phc.rs:824
↓ 2 callersFunctionget_ptp_uevent_file_paths_for_pci_slot
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
clock-bound/src/daemon/io/phc.rs:736
↓ 2 callersFunctionget_uevent_file_path_for_network_interface
Gets the uevent file path for a particular network interface.
clock-bound/src/daemon/io/phc.rs:662
↓ 2 callersMethodget_value_tsc
(&self, rng: &mut dyn rand::RngCore)
clock-bound-ff-tester/src/simulation/delay.rs:51
↓ 2 callersMethodhandle_clock_parameters
Handles `ClockParameters` passed out from the `ClockSyncAlgorithm` selector. # Panics If the `ClockAdjuster` fails, e.g. an invalid value was supplie
clock-bound/src/daemon/clock_state.rs:236
↓ 2 callersMethodhandle_clock_parameters_shm1
Handles `ClockParameters` passed out from the `ClockSyncAlgorithm` selector for SHM1 (`ClockErrorBoundV3`)
clock-bound/src/daemon/clock_state/clock_state_writer.rs:94
↓ 2 callersMethodhandle_disruption
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
clock-bound/src/daemon/clock_state.rs:249
↓ 2 callersMethodhandle_disruption
(&mut self, _new_disruption_marker: u64)
clock-bound/src/daemon/clock_state/clock_adjust.rs:65
↓ 2 callersMethodhandle_disruption
Handles a clock disruption event Changes the source's mode to [`Mode::Burst`] and the polling frequency to [`BURST_INTERVAL_DURATION`].
clock-bound/src/daemon/io/link_local.rs:217
↓ 2 callersMethodhandle_event
Central event handler for `ClockAdjuster`. The state machine mostly consists of transitions based on time elapsed since last state. Handling of these
clock-bound/src/daemon/clock_state/clock_adjust.rs:130
↓ 2 callersMethodhandle_tick
(&mut self, now: tokio::time::Instant)
clock-bound/src/daemon/clock_state.rs:209
↓ 2 callersMethodhas_next
Determines if another NTP event can be generated within the time series bounds # Returns `true` if the next poll time is within the bounds of all tim
clock-bound-ff-tester/src/simulation/ntp/series.rs:245
↓ 2 callersFunctioninit
Initialize the tracing subscriber This currently uses the [`tracing_subscriber::registry()`] to have 2 different paths. Clock synchronization events
clock-bound/src/daemon/subscriber.rs:23
↓ 2 callersMethodinitialize_ceb_v2_shm
Initialize the `ClockErrorBoundV2` segment on daemon startup. ClockBound 2.0 clients rely on the OS system clock to 1) create a timestamp, and 2) gro
clock-bound/src/daemon/clock_state/clock_state_writer.rs:80
↓ 2 callersMethodis_empty
Returns true if empty
clock-bound/src/daemon/clock_sync_algorithm/ff/event_buffer/local.rs:90
↓ 2 callersMethodlength
Returns the total Length field value as defined in RFC 5905 The Length field is a 16-bit unsigned integer that indicates the length of the entire ext
clock-bound/src/daemon/io/ntp/packet/extension.rs:78
↓ 2 callersFunctionlinear_rounded
(x: T, x0: T, x1: T, y0: U, y1: U)
clock-bound-ff-tester/src/simulation/interpolation.rs:41
↓ 2 callersMethodmean
(&self)
clock-bound-ff-tester/src/simulation/stats/normal.rs:30
↓ 2 callersMethodnext_event
Generate the next event
clock-bound-ff-tester/src/simulation/vmclock.rs:84
↓ 2 callersMethodnext_event_ready
(&self, oscillator: &FullModel)
clock-bound-ff-tester/src/simulation/vmclock.rs:153
↓ 2 callersMethodnow
Retrieves the current time. # Errors Returns an error if the clock bound time retrieval fails.
test/clock-bound-client-generic/src/lib.rs:122
↓ 2 callersFunctionoscillator_skew_ppm
()
clock-bound-ff-tester/src/simulation/ntp/series.rs:560
↓ 2 callersFunctionparse
()
clock-bound/src/daemon/io/ntp/packet/short.rs:164
↓ 2 callersFunctionperfect_symmetric
(scenario_duration: TrueDuration)
clock-bound-ff-tester/src/sim_phc.rs:59
↓ 2 callersMethodphc
(&self)
clock-bound/src/daemon/io.rs:188
↓ 2 callersMethodprops
Getter for this generator's props
clock-bound-ff-tester/src/simulation/ntp/dispersion_increase_linear.rs:149
↓ 2 callersMethodpush
Pushes a new value into the buffer, overwriting the oldest value if the buffer is full Returns the value that was overwritten, if any
clock-bound/src/daemon/async_ring_buffer.rs:224
↓ 2 callersMethodread
(&self)
test/clock-bound-phc-offset/src/phc/ceb.rs:26
↓ 2 callersFunctionread_timestamp_counter_end
()
clock-bound/src/shm/tsc.rs:16
↓ 2 callersFunctionremove_path_if_exists
(path_shm: &str)
clock-bound/src/shm/writer.rs:357
↓ 2 callersFunctionrepro_events_from_reader
Convert a log file at `file_path` into a `ff-tester` scenario Returns a Scenario, and the output from every call into `ClockSyncAlgorithm::feed_link_
clock-bound-ff-tester/src/repro.rs:47
↓ 2 callersMethodrng_mut
(&mut self)
clock-bound-ff-tester/src/simulation/oscillator.rs:97
↓ 2 callersMethodsample
Pulls a samples from the Normal distribution.
clock-bound-ff-tester/src/simulation/stats/normal.rs:44
↓ 2 callersFunctionsample_packet
Sample an NTP event Send an NTP request and return the response This function will effectively loop over: - receiving a packet - parsing it - ensuri
clock-bound/src/daemon/io/ntp.rs:59
↓ 2 callersFunctionserialize_scenario
( path: Option<&PathBuf>, scenario: &TesterScenario, )
clock-bound-ff-tester/src/bin/scenario_generator.rs:330
↓ 2 callersFunctionserialize_to_writer_pretty
Serialize using json to a writer # Errors Errors if unable to write
clock-bound-ff-tester/src/events.rs:28
↓ 2 callersFunctionsetup
Set up ntp source io for testing
test/ntp-source/src/main.rs:36
↓ 2 callersMethodsnapshot
(&mut self)
clock-bound/src/daemon/io/vmclock.rs:32
↓ 2 callersMethodsnapshot
(&mut self)
clock-bound/src/vmclock/shm_reader.rs:261
↓ 2 callersMethodsystem_clock
(&self)
clock-bound/src/daemon/event/phc.rs:70
↓ 2 callersFunctiontester_event_from_cb_phc
(event: &event::Phc, source_id: String)
clock-bound-ff-tester/src/repro.rs:114
↓ 2 callersMethodto_time_delta
Convert to time delta
clock-bound/src/daemon/io/ntp/packet/short.rs:51
↓ 2 callersMethodto_time_delta_since_ntp_epoch
Convert to time since the NTP epoch NTP epoch is 1/1/1900-00:00h. NOTE that this is different from the UNIX epoch at 1970
clock-bound/src/daemon/io/ntp/packet/timestamp.rs:59
↓ 2 callersMethodto_time_delta_since_unix_epoch
Convert to time since UNIX epoch
clock-bound/src/daemon/io/ntp/packet/timestamp.rs:71
↓ 2 callersMethodto_timeval_nanos
(self)
clock-bound/src/daemon/time/inner.rs:644
↓ 2 callersMethodto_timex_freq
In struct timex, freq, ppsfreq, and stabil are ppm (parts per million) with a 16-bit fractional part, which means that a value of 1 in one of those fi
clock-bound/src/daemon/time/tsc.rs:349
↓ 2 callersMethodtransition_to_normal_mode
Changes the source's mode to [`Mode::Normal`] and changes polling frequency to [`LINK_LOCAL_INTERVAL_DURATION`].
clock-bound/src/daemon/io/link_local.rs:242
↓ 2 callersMethodtsc_post
(&self)
clock-bound/src/daemon/receiver_stream.rs:163
↓ 2 callersMethodtsc_pre
(&self)
clock-bound/src/daemon/receiver_stream.rs:156
↓ 2 callersMethodtsc_timestamp_start
TSC Timestamp Start
clock-bound-ff-tester/src/events/v1/oscillator.rs:62
↓ 2 callersMethoduncorrected_time
Get an uncorrected time value `Cu(t) = TSC(t) * p + K`, where - `Cu(t)` is the uncorrected time value, and return value - `TSC(t)` is the raw TSC val
clock-bound/src/daemon/time/tsc.rs:66
↓ 2 callersMethodvmclock
Returns `VMCLock` if it has been initialized
clock-bound/src/daemon/io.rs:258
↓ 2 callersFunctionwrite_vmclock_content
(file: &mut File, vmclock_content: &VMClockContent)
test/link-local/src/vmclock.rs:7
↓ 1 callersMethodadd_ntp_source
Adds a new ntp source to the `ntp_sources`
clock-bound/src/daemon/receiver_stream.rs:46
↓ 1 callersFunctionautoconfigure_phc_reader
()
test/clock-bound-phc-offset/src/phc/autoconfiguration.rs:46
← previousnext →201–300 of 1,214, ranked by callers