kache 1.1.1

Compiler cache for Rust, C/C++ and CUDA, with S3, GCS, shared-filesystem and OCI remotes.
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
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113

use super::*;
use crate::store::Store;

#[test]
fn horizon_is_independent_of_event_window_and_reads_production_schema() {
    let dir = tempfile::tempdir().unwrap();
    let config = crate::test_support::test_config(dir.path().to_path_buf());
    let store = Store::open(&config).unwrap();
    let db = rusqlite::Connection::open(config.index_db_path()).unwrap();
    db.execute("INSERT INTO eviction_tombstones(cache_key,evicted_at,policy,size,hit_count,idle_hours,compile_time_ms,demanded_at,shadow_policy,shadow_would_evict) VALUES ('old',datetime(100,'unixepoch'),'lru',1073741824,0,0,900,datetime(604900,'unixepoch'),'value-density',1)",[]).unwrap();
    drop(db);
    drop(store);
    // Reopen for report after the last WAL owner has closed.
    let inventory = crate::store_view::read_report(&config, 604_900, HORIZON_SECS).unwrap();
    let evidence = collect(inventory.eviction_evidence, 604_900);
    assert_eq!(evidence.horizon_secs, 604_800);
    assert!(
        crate::store_view::read(&config, false, "name")
            .unwrap()
            .eviction_evidence
            .is_empty()
    );
    let row = evidence.stores[0].evidence.as_ref().unwrap();
    assert_eq!(row.live_shadow_agreed.mature, 1);
    assert_eq!(
        row.live_shadow_agreed.demanded_gross_compile_cost_ms_lower,
        900
    );
    assert!(evidence.stores[0].error.is_none());
    let text = lines(&evidence).join("\n");
    assert!(text.contains("900.0–900.0ms/logical GiB"));
    assert!(text.contains("independent of the build-event window"));
    assert!(text.contains("unknown cost 0"));
}

#[test]
fn missing_index_is_reported_without_creation_or_path_leaks() {
    let dir = tempfile::tempdir().unwrap();
    let missing = dir.path().join("private-missing");
    let mut config = crate::test_support::test_config(dir.path().join("main"));
    config.volume_stores.push(crate::config::VolumeStore {
        volume: dir.path().to_string_lossy().into_owned(),
        store: missing.clone(),
        max_size: Some(1 << 30),
    });
    let inventory = crate::store_view::read_report(&config, 900_000, HORIZON_SECS).unwrap();
    let evidence = collect(inventory.eviction_evidence, 900_000);
    assert!(!missing.exists());
    assert!(evidence.stores[1].evidence.is_none());
    assert_eq!(
        evidence.stores[1].error.as_deref(),
        Some("index unavailable")
    );
    let json = serde_json::to_string(&evidence).unwrap();
    assert!(!json.contains("private-missing"));
    assert!(
        lines(&evidence)
            .join("\n")
            .contains("Store 1: index unavailable")
    );
}

#[test]
fn json_and_full_formats_include_limits_and_old_reports_deserialize() {
    let dir = tempfile::tempdir().unwrap();
    let config = crate::test_support::test_config(dir.path().to_path_buf());
    let report =
        super::super::generate_report(&config, crate::since::SinceWindow::DEFAULT, 10).unwrap();
    let json = serde_json::to_value(&report).unwrap();
    assert_eq!(json["eviction_evidence"]["horizon_secs"], 604800);
    let limits = json["eviction_evidence"]["limitations"].as_array().unwrap();
    assert!(
        limits
            .iter()
            .any(|s| s.as_str().unwrap().contains("gross measured compile time"))
    );
    assert!(
        limits
            .iter()
            .any(|s| s.as_str().unwrap().contains("shared blobs"))
    );
    assert!(super::super::format_text(&report).contains("Eviction observations"));
    assert!(super::super::format_markdown(&report).contains("Immature and invalid"));
    let mut old = json;
    old.as_object_mut().unwrap().remove("eviction_evidence");
    let old: super::super::BuildReport = serde_json::from_value(old).unwrap();
    assert!(old.eviction_evidence.is_none());
}

#[test]
fn distinct_cohorts_and_missing_cost_remain_visible() {
    let mut evidence = EvictionHorizonEvidence::default();
    evidence.live_shadow_agreed.mature = 2;
    evidence.live_shadow_agreed.unknown_compile_cost = 1;
    evidence.live_shadow_kept.immature = 3;
    evidence.shadow_only.invalid = 4;
    let report = EvictionEvidenceReport {
        horizon_secs: 604800,
        as_of_unix_secs: 900000,
        limitations: vec![],
        stores: vec![StoreEvidence {
            store_index: 5,
            evidence: Some(evidence),
            error: None,
        }],
    };
    let text = lines(&report).join("\n");
    assert!(text.contains("Store 5 live/shadow agreed: 2 mature, 0 immature, 0 invalid"));
    assert!(text.contains("Store 5 live/shadow kept: 0 mature, 3 immature, 0 invalid"));
    assert!(text.contains("Store 5 shadow only: 0 mature, 0 immature, 4 invalid"));
    assert!(text.contains("unknown cost 1"));
    assert!(text.contains("0–0ms (unavailable)"));
}