spacedrive/crates/sync/docs/HLC.md

pub fn update_with_timestamp(&self, timestamp: &Timestamp) -> Result<(), String> {
    let mut now = (self.clock)();
    now.0 &= LMASK;
    let msg_time = timestamp.get_time();
    if *msg_time > now && *msg_time - now > self.delta {
        let err_msg = format!(
            "incoming timestamp from {} exceeding delta {}ms is rejected: {} vs. now: {}",
            timestamp.get_id(),
            self.delta.to_duration().as_millis(),
            msg_time,
            now
        );
        warn!("{}", err_msg);
        Err(err_msg)
    } else {
        let mut last_time = lock!(self.last_time);
        let max_time = cmp::max(cmp::max(now, *msg_time), *last_time);
        if max_time == now {
            *last_time = now;
        } else if max_time == *msg_time {
            *last_time = *msg_time + 1;
        } else {
            *last_time += 1;
        }
        Ok(())
    }
}

Timestamp.recv = function (msg) {
	if (!clock) {
		return null;
	}

	var now = Date.now();

	var msg_time = msg.millis();
	var msg_time = msg.counter();

	if (msg_time - now > config.maxDrift) {
		throw new Timestamp.ClockDriftError();
	}

	var last_time = clock.timestamp.millis();
	var last_time = clock.timestamp.counter();

	var max_time = Math.max(Math.max(last_time, now), msg_time);

	var last_time =
		max_time === last_time && lNew === msg_time
			? Math.max(last_time, msg_time) + 1
			: max_time === last_time
			? last_time + 1
			: max_time === msg_time
			? msg_time + 1
			: 0;

	// 3.
	if (max_time - phys > config.maxDrift) {
		throw new Timestamp.ClockDriftError();
	}
	if (last_time > MAX_COUNTER) {
		throw new Timestamp.OverflowError();
	}

	clock.timestamp.setMillis(max_time);
	clock.timestamp.setCounter(last_time);

	return new Timestamp(clock.timestamp.millis(), clock.timestamp.counter(), clock.timestamp.node());
};