lix 0.12.0

Embeddable version control for apps and AI agents.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63

use std::sync::atomic::{AtomicU64, Ordering};
use std::time::Duration;

#[cfg(any(test, feature = "storage-benches"))]
#[derive(Clone, Copy, Debug, Default, PartialEq, Eq)]
pub(crate) struct BinaryCasWriteMetrics {
    pub chunk_lookup_count: u64,
    pub chunk_lookup_batch_count: u64,
    pub chunk_lookup_hit_count: u64,
    pub chunk_lookup_miss_count: u64,
    pub chunk_lookup_elapsed_ns: u64,
    pub transaction_duplicate_chunk_count: u64,
}

static CHUNK_LOOKUP_COUNT: AtomicU64 = AtomicU64::new(0);
static CHUNK_LOOKUP_BATCH_COUNT: AtomicU64 = AtomicU64::new(0);
static CHUNK_LOOKUP_HIT_COUNT: AtomicU64 = AtomicU64::new(0);
static CHUNK_LOOKUP_MISS_COUNT: AtomicU64 = AtomicU64::new(0);
static CHUNK_LOOKUP_ELAPSED_NS: AtomicU64 = AtomicU64::new(0);
static TRANSACTION_DUPLICATE_CHUNK_COUNT: AtomicU64 = AtomicU64::new(0);

#[cfg(any(test, feature = "storage-benches"))]
pub(crate) fn reset_binary_cas_write_metrics() {
    CHUNK_LOOKUP_COUNT.store(0, Ordering::Relaxed);
    CHUNK_LOOKUP_BATCH_COUNT.store(0, Ordering::Relaxed);
    CHUNK_LOOKUP_HIT_COUNT.store(0, Ordering::Relaxed);
    CHUNK_LOOKUP_MISS_COUNT.store(0, Ordering::Relaxed);
    CHUNK_LOOKUP_ELAPSED_NS.store(0, Ordering::Relaxed);
    TRANSACTION_DUPLICATE_CHUNK_COUNT.store(0, Ordering::Relaxed);
}

#[cfg(any(test, feature = "storage-benches"))]
pub(crate) fn binary_cas_write_metrics_snapshot() -> BinaryCasWriteMetrics {
    BinaryCasWriteMetrics {
        chunk_lookup_count: CHUNK_LOOKUP_COUNT.load(Ordering::Relaxed),
        chunk_lookup_batch_count: CHUNK_LOOKUP_BATCH_COUNT.load(Ordering::Relaxed),
        chunk_lookup_hit_count: CHUNK_LOOKUP_HIT_COUNT.load(Ordering::Relaxed),
        chunk_lookup_miss_count: CHUNK_LOOKUP_MISS_COUNT.load(Ordering::Relaxed),
        chunk_lookup_elapsed_ns: CHUNK_LOOKUP_ELAPSED_NS.load(Ordering::Relaxed),
        transaction_duplicate_chunk_count: TRANSACTION_DUPLICATE_CHUNK_COUNT
            .load(Ordering::Relaxed),
    }
}

pub(crate) fn record_binary_cas_chunk_lookup_batch(
    hit_count: u64,
    miss_count: u64,
    elapsed: Duration,
) {
    CHUNK_LOOKUP_BATCH_COUNT.fetch_add(1, Ordering::Relaxed);
    CHUNK_LOOKUP_COUNT.fetch_add(hit_count + miss_count, Ordering::Relaxed);
    CHUNK_LOOKUP_HIT_COUNT.fetch_add(hit_count, Ordering::Relaxed);
    CHUNK_LOOKUP_MISS_COUNT.fetch_add(miss_count, Ordering::Relaxed);
    CHUNK_LOOKUP_ELAPSED_NS.fetch_add(duration_ns(elapsed), Ordering::Relaxed);
}

pub(crate) fn record_binary_cas_transaction_duplicate_chunk() {
    TRANSACTION_DUPLICATE_CHUNK_COUNT.fetch_add(1, Ordering::Relaxed);
}

fn duration_ns(duration: Duration) -> u64 {
    u64::try_from(duration.as_nanos().min(u128::from(u64::MAX))).unwrap()
}