aboutsummaryrefslogtreecommitdiff
path: root/src/server
diff options
context:
space:
mode:
authorOgulcan Celik <ogulcancelik@gmail.com>2026-06-07 00:34:53 +0300
committerOgulcan Celik <ogulcancelik@gmail.com>2026-06-07 16:29:45 +0300
commit52e57507e10ee7cb2869156fb1f00e280e614736 (patch)
tree0c9006a6b315a25f88721c8dbc75fa3a85c4379e /src/server
parentb5fba2fdd15aa4cab9621c383f72b57644078fd5 (diff)
ci: tighten windows branch validation
Diffstat (limited to 'src/server')
-rw-r--r--src/server/autodetect.rs2
-rw-r--r--src/server/client_transport.rs25
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]