aboutsummaryrefslogtreecommitdiff
path: root/tests/cli_wrapper.rs
diff options
context:
space:
mode:
authorOgulcan Celik <ogulcancelik@gmail.com>2026-07-05 02:17:45 +0300
committerOgulcan Celik <ogulcancelik@gmail.com>2026-07-05 02:17:45 +0300
commitc78349f422139577f8d7bf5e07f84dcec5a48456 (patch)
tree049cd25431acd355a1ab0923a2e0b6778f766e35 /tests/cli_wrapper.rs
parenta4935886afffddf168bec4bbacacf9def6d1776b (diff)
fix: wait for server stop socket cleanup
Diffstat (limited to 'tests/cli_wrapper.rs')
-rw-r--r--tests/cli_wrapper.rs20
1 files changed, 7 insertions, 13 deletions
diff --git a/tests/cli_wrapper.rs b/tests/cli_wrapper.rs
index c1bf27c0..d3f67780 100644
--- a/tests/cli_wrapper.rs
+++ b/tests/cli_wrapper.rs
@@ -1756,26 +1756,20 @@ fn server_stop_command_shuts_down_running_server() {
"server stop should not print stdout: {}",
String::from_utf8_lossy(&stopped.stdout)
);
-
- let pid = herdr.child.process_id();
- let exit_status = herdr.child.wait().unwrap();
- unregister_spawned_herdr_pid(pid);
- assert!(exit_status.success(), "server stop should exit cleanly");
-
- let deadline = Instant::now() + Duration::from_secs(3);
- while Instant::now() < deadline && (socket_path.exists() || client_socket.exists()) {
- thread::sleep(Duration::from_millis(25));
- }
-
assert!(
!socket_path.exists() || UnixStream::connect(&socket_path).is_err(),
- "api socket should be removed or stale after server stop"
+ "api socket should be removed or stale before server stop returns"
);
assert!(
!client_socket.exists() || UnixStream::connect(&client_socket).is_err(),
- "client socket should be removed or stale after server stop"
+ "client socket should be removed or stale before server stop returns"
);
+ let pid = herdr.child.process_id();
+ let exit_status = herdr.child.wait().unwrap();
+ unregister_spawned_herdr_pid(pid);
+ assert!(exit_status.success(), "server stop should exit cleanly");
+
cleanup_spawned_herdr(herdr, base);
}