Struct MeshClockSync 

pub struct MeshClockSync {
    pub offset_us: i64,
    pub authority_id: Option<String>,
    pub authority_source: ClockSource,
    pub local_source: ClockSource,
    pub sync_count: u64,
    pub uncertainty_us: u64,
    /* private fields */
}

Mesh time synchronization state for a node.

Fields

offset_us: i64

Current clock offset from authority (microseconds, signed).

authority_id: Option<String>

ID of the current time authority node.

authority_source: ClockSource

Clock source of the authority.

local_source: ClockSource

Our own clock source.

sync_count: u64

Number of sync samples received.

uncertainty_us: u64

Estimated clock uncertainty (microseconds).

Implementations

impl MeshClockSync

pub fn new(local_source: ClockSource) -> Self

Create a new clock sync state.

pub fn mesh_time_us(&self) -> u64

Get the current mesh-synchronized time in microseconds since epoch.

Uses RealClock. Prefer Self::mesh_time_us_with when a Clock is available (tests / DI).

pub fn mesh_time_us_with(&self, clock: &dyn Clock) -> u64

Mesh-synchronized time using an injectable Clock.

pub fn process_sync( &mut self, sender_id: &str, sender_time_us: u64, sender_source: ClockSource, local_receive_time_us: u64, )

Process a time sync sample from a heartbeat.

If the sender has a better clock source, update our offset. Uses exponential moving average to smooth jitter.

pub fn is_authority(&self, our_node_id: &str) -> bool

Check if this node should be the time authority.

pub fn is_better_source(&self, other: ClockSource) -> bool

Whether we have a better clock source than the given source.

Trait Implementations

impl Clone for MeshClockSync

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for MeshClockSync

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.