diff options
| author | Ogulcan Celik <ogulcancelik@gmail.com> | 2026-06-07 00:34:53 +0300 |
|---|---|---|
| committer | Ogulcan Celik <ogulcancelik@gmail.com> | 2026-06-07 16:29:45 +0300 |
| commit | 52e57507e10ee7cb2869156fb1f00e280e614736 (patch) | |
| tree | 0c9006a6b315a25f88721c8dbc75fa3a85c4379e /src/server | |
| parent | b5fba2fdd15aa4cab9621c383f72b57644078fd5 (diff) | |
ci: tighten windows branch validation
Diffstat (limited to 'src/server')
| -rw-r--r-- | src/server/autodetect.rs | 2 | ||||
| -rw-r--r-- | src/server/client_transport.rs | 25 |
2 files changed, 23 insertions, 4 deletions
diff --git a/src/server/autodetect.rs b/src/server/autodetect.rs index cdba5bd2..f40be988 100644 --- a/src/server/autodetect.rs +++ b/src/server/autodetect.rs @@ -55,7 +55,7 @@ fn is_server_listening_at(socket_path: &Path) -> bool { #[cfg(windows)] { let _ = socket_path; - return read_server_status().ok().flatten().is_some(); + read_server_status().ok().flatten().is_some() } #[cfg(not(windows))] diff --git a/src/server/client_transport.rs b/src/server/client_transport.rs index 4f0f12bc..4bbf7bbf 100644 --- a/src/server/client_transport.rs +++ b/src/server/client_transport.rs @@ -531,21 +531,40 @@ fn client_read_loop( mod tests { use super::*; use interprocess::local_socket::traits::Listener as _; + use std::path::PathBuf; + + struct TestSocketPath(PathBuf); + + impl Drop for TestSocketPath { + fn drop(&mut self) { + let _ = std::fs::remove_file(&self.0); + } + } fn unique_test_path(name: &str) -> std::path::PathBuf { let nanos = std::time::SystemTime::now() .duration_since(std::time::UNIX_EPOCH) .unwrap() .as_nanos(); - std::env::temp_dir().join(format!("herdr-{name}-{}-{nanos}", std::process::id())) + let filename = format!("h{}-{nanos}.sock", std::process::id()); + #[cfg(unix)] + { + let _ = name; + PathBuf::from("/tmp").join(filename) + } + #[cfg(windows)] + { + std::env::temp_dir().join(format!("herdr-{name}-{filename}")) + } } - fn local_stream_pair(name: &str) -> (LocalStream, LocalStream, std::path::PathBuf) { + fn local_stream_pair(name: &str) -> (LocalStream, LocalStream, TestSocketPath) { let path = unique_test_path(name); + let _ = std::fs::remove_file(&path); let listener = crate::ipc::bind_local_listener(&path).unwrap(); let client = crate::ipc::connect_local_stream(&path).unwrap(); let server = listener.accept().unwrap(); - (client, server, path) + (client, server, TestSocketPath(path)) } #[test] |
