lib

commit a72c713ead7eea7463d98e952e0c630bb7cfc540
parent 3c7aef4bfc233ae9d80d1c8172373ac566e136b0
Author: triesap <tyson@radroots.org>
Date:   Thu, 13 Aug 2026 14:48:00 +0000

sdk: stabilize loopback transport tests

Serialize the loopback HTTP fixtures that share tight timing assumptions. Give non-timeout fixtures scheduling headroom while preserving the explicit timeout case. Keep production transport behavior unchanged and retain the canonical parallel test command.

Diffstat:
M
crates/sdk/src/adapters/blossom.rs
 | 
18
+++++++++++++-----

1 file changed, 13 insertions(+), 5 deletions(-)
diff --git a/crates/sdk/src/adapters/blossom.rs b/crates/sdk/src/adapters/blossom.rs
@@ -1186,6 +1186,8 @@ mod tests {
     use tokio::io::{AsyncReadExt, AsyncWriteExt};
     use tokio::net::TcpListener;
 
+    static LOOPBACK_TEST_GUARD: tokio::sync::Mutex<()> = tokio::sync::Mutex::const_new(());
+
     fn png(width: u32, height: u32) -> Vec<u8> {
         let mut bytes = b"\x89PNG\r\n\x1a\n\0\0\0\rIHDR".to_vec();
         bytes.extend_from_slice(&width.to_be_bytes());
@@ -1491,6 +1493,7 @@ mod tests {
 
     #[tokio::test]
     async fn http_failure_retains_only_the_public_server_error_code() {
+        let _loopback_guard = LOOPBACK_TEST_GUARD.lock().await;
         let listener = TcpListener::bind("127.0.0.1:0").await.expect("bind");
         let address = listener.local_addr().expect("address");
         let server = tokio::spawn(async move {
@@ -1719,7 +1722,7 @@ mod tests {
                         .expect("oversize");
                 }
                 RetrievalResponse::Stall => {
-                    tokio::time::sleep(Duration::from_secs(1)).await;
+                    tokio::time::sleep(Duration::from_secs(3)).await;
                 }
             }
             retrieval_stream.shutdown().await.expect("retrieval close");
@@ -1805,8 +1808,8 @@ mod tests {
     fn config(origin: &str) -> BlossomConfig {
         BlossomConfig::from_profile(simulator_profile(origin))
             .with_network_policy(
-                Duration::from_millis(100),
-                Duration::from_millis(100),
+                Duration::from_secs(2),
+                Duration::from_secs(2),
                 1,
                 Duration::from_millis(1),
             )
@@ -1825,6 +1828,7 @@ mod tests {
 
     #[tokio::test]
     async fn non_mutating_probe_records_only_dns_transport_and_http_evidence() {
+        let _loopback_guard = LOOPBACK_TEST_GUARD.lock().await;
         let listener = TcpListener::bind("127.0.0.1:0").await.unwrap();
         let address = listener.local_addr().unwrap();
         let server = tokio::spawn(async move {
@@ -1884,6 +1888,7 @@ mod tests {
 
     #[tokio::test]
     async fn reconfiguration_during_probe_cannot_promote_stale_evidence() {
+        let _loopback_guard = LOOPBACK_TEST_GUARD.lock().await;
         let listener = TcpListener::bind("127.0.0.1:0").await.unwrap();
         let address = listener.local_addr().unwrap();
         let (accepted_tx, accepted_rx) = tokio::sync::oneshot::channel();
@@ -1924,6 +1929,7 @@ mod tests {
 
     #[tokio::test]
     async fn loopback_upload_preserves_exact_bytes_and_verifies_retrieval() {
+        let _loopback_guard = LOOPBACK_TEST_GUARD.lock().await;
         let bytes = png(2, 3);
         let (origin, server) = spawn_server(bytes.clone(), RetrievalResponse::Exact, false).await;
         let receipt = upload_with_authorization(
@@ -1953,12 +1959,13 @@ mod tests {
 
     #[tokio::test]
     async fn retryable_upload_and_retrieval_failures_recover_with_bounded_attempts() {
+        let _loopback_guard = LOOPBACK_TEST_GUARD.lock().await;
         let bytes = png(2, 3);
         let (origin, server) = spawn_retry_server(bytes.clone()).await;
         let config = BlossomConfig::from_profile(simulator_profile(origin.as_str()))
             .with_network_policy(
-                Duration::from_millis(100),
-                Duration::from_millis(100),
+                Duration::from_secs(2),
+                Duration::from_secs(2),
                 2,
                 Duration::from_millis(1),
             )
@@ -1977,6 +1984,7 @@ mod tests {
 
     #[tokio::test]
     async fn descriptor_redirect_body_mime_timeout_and_cancellation_fail_closed() {
+        let _loopback_guard = LOOPBACK_TEST_GUARD.lock().await;
         let cases = [
             (
                 RetrievalResponse::Exact,