Function update_max

packages/server/src/metrics/counters.rs:200–208

(target: &AtomicU64, value: u64)

}

fn update_max(target: &AtomicU64, value: u64) {
    let mut current = target.load(Ordering::Relaxed);
    while value > current {
        match target.compare_exchange(current, value, Ordering::Relaxed, Ordering::Relaxed) {
            Ok(_) => break,
            Err(next) => current = next,
        }
    }
}

fn prune_stale_client_stream_stats(snapshots: &mut VecDeque<ClientStreamStats>) {
    let now_ms = current_time_ms();