chore(release): prepare 0.16.1

Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name = "kache"
-version = "0.16.0"
+version = "0.16.1"
 edition = "2024"
 description = "Zero-copy, content-addressed build cache for Rust, C/C++ and more, with S3 and shared-filesystem remotes."
 license = "Apache-2.0"
@@ -41,7 +41,7 @@ reqsign-aws-v4 = { version = "=3.3.0", default-features = false }
 reqsign-core = { version = "=3.3.1", default-features = false }
 # Direct dep so OpenDAL/reqwest can use ring without reintroducing aws-lc.
 rustls = { version = "0.23", default-features = false, features = ["ring"] }
-kache-core = { version = "0.16.0", path = "crates/kache-core", default-features = false, features = ["planning"] }
+kache-core = { version = "0.16.1", path = "crates/kache-core", default-features = false, features = ["planning"] }
 async-trait = "0.1"
 tokio = { version = "1", features = ["rt", "rt-multi-thread", "macros", "process", "fs", "io-util", "net", "time", "signal", "sync"] }
 serde = { version = "1", features = ["derive"] }

charts/kache-service/Chart.yaml

@@ -2,8 +2,8 @@ apiVersion: v2
 name: kache-service
 description: Advisory remote planner service for kache
 type: application
-version: 0.16.0
-appVersion: "0.16.0"
+version: 0.16.1
+appVersion: "0.16.1"
 keywords:
   - rust
   - cache

crates/kache-core/Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name = "kache-core"
-version = "0.16.0"
+version = "0.16.1"
 edition = "2024"
 description = "Core planner data structures and algorithms for kache."
 license = "Apache-2.0"

crates/kache-e2e/Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name = "kache-e2e"
-version = "0.16.0"
+version = "0.16.1"
 edition = "2024"
 license = "Apache-2.0"
 repository = "https://github.com/kunobi-ninja/kache"

crates/kache-proofs/Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name = "kache-proofs"
-version = "0.0.0"
+version = "0.16.1"
 publish = false
 edition = "2024"
 description = "Repository-only formal verification harnesses for kache."

crates/kache-service/Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name = "kache-service"
-version = "0.16.0"
+version = "0.16.1"
 edition = "2024"
 description = "Remote service shell for kache planner endpoints"
 license = "Apache-2.0"

src/daemon.rs

@@ -14191,21 +14191,33 @@ mod tests {
             "prefetch dispatch is ok even if downloads fail: {resp:?}"
         );
 
-        // Poll the failure counter; the download runs in the background.
-        let mut failed = false;
-        for _ in 0..100 {
-            if daemon
-                .transfer_counters
-                .downloads_failed
-                .load(Ordering::Relaxed)
-                >= 1
-            {
-                failed = true;
-                break;
+        // The download runs in the background. downloads_failed is bumped
+        // before the TransferEvent is pushed, so waiting on the counter
+        // alone races on Windows. Wait for both, same as
+        // prefetch_import_failure_is_counted_as_failure.
+        let completed = tokio::time::timeout(Duration::from_secs(5), async {
+            loop {
+                let failed = daemon
+                    .transfer_counters
+                    .downloads_failed
+                    .load(Ordering::Relaxed);
+                let has_event = daemon
+                    .recent_transfers
+                    .lock()
+                    .unwrap_or_else(|poisoned| poisoned.into_inner())
+                    .back()
+                    .is_some();
+                if failed >= 1 && has_event {
+                    break;
+                }
+                tokio::task::yield_now().await;
             }
-            tokio::time::sleep(Duration::from_millis(50)).await;
-        }
-        assert!(failed, "a garbage pack must record a failed download");
+        })
+        .await;
+        assert!(
+            completed.is_ok(),
+            "a garbage pack must record a failed download and a transfer event"
+        );
         assert_v3_transfer_timestamps(&latest_transfer(&daemon));
         // Nothing was imported.
         assert!(!config.store_dir().join(key).join("meta.json").exists());