From 2b022a6a7f94581a3b16671b806266c6cc8a8ec0 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Fabr=C3=ADcio=20Bracht?= Date: Sat, 10 Oct 2026 15:47:47 -0700 Subject: [PATCH] measure lock hold time, not reopen time, in the bridged storage lock test --- crates/mqtt5/tests/broker_storage_lock.rs | 8 +++++--- 1 file changed, 5 insertions(+), 3 deletions(-) diff --git a/crates/mqtt5/tests/broker_storage_lock.rs b/crates/mqtt5/tests/broker_storage_lock.rs index bf2f9a4e..0385cebe 100644 --- a/crates/mqtt5/tests/broker_storage_lock.rs +++ b/crates/mqtt5/tests/broker_storage_lock.rs @@ -186,16 +186,18 @@ async fn bridged_broker_releases_the_directory_promptly_after_shutdown() { .expect("broker task joins") .expect("broker run returns cleanly"); let began = Instant::now(); + let mut attempt_began = began; let mut reopened = FileBackend::new(dir.path()).await; while reopened.is_err() && began.elapsed() < Duration::from_secs(2) { tokio::time::sleep(Duration::from_millis(5)).await; + attempt_began = Instant::now(); reopened = FileBackend::new(dir.path()).await; } - let waited = began.elapsed(); + let held = attempt_began.duration_since(began); drop(reopened.expect("directory is released after shutdown")); assert!( - waited < Duration::from_millis(400), - "directory held for {waited:?} after run returned" + held < Duration::from_millis(400), + "directory held for {held:?} after run returned" ); remote_shutdown.shutdown();