aboutsummaryrefslogtreecommitdiff
path: root/src
diff options
context:
space:
mode:
Diffstat (limited to 'src')
-rw-r--r--src/api/server/pane_graphics_stream.rs13
1 files changed, 6 insertions, 7 deletions
diff --git a/src/api/server/pane_graphics_stream.rs b/src/api/server/pane_graphics_stream.rs
index c6c58052..a58c0f08 100644
--- a/src/api/server/pane_graphics_stream.rs
+++ b/src/api/server/pane_graphics_stream.rs
@@ -568,19 +568,18 @@ mod tests {
use interprocess::local_socket::traits::Listener as _;
use std::io::{BufRead, BufReader, Write};
use std::path::PathBuf;
- use std::sync::atomic::{AtomicBool, Ordering};
+ use std::sync::atomic::{AtomicBool, AtomicU64, Ordering};
use std::sync::Arc;
use std::time::{Duration, Instant};
use tokio::sync::mpsc;
- fn local_stream_pair(name: &str) -> (LocalStream, LocalStream, PathBuf) {
+ static NEXT_LOCAL_STREAM_ID: AtomicU64 = AtomicU64::new(1);
+
+ fn local_stream_pair(_name: &str) -> (LocalStream, LocalStream, PathBuf) {
let unique = format!(
- "herdr-{name}-{}-{}",
+ "hpg-{}-{}.sock",
std::process::id(),
- std::time::SystemTime::now()
- .duration_since(std::time::UNIX_EPOCH)
- .unwrap()
- .as_nanos()
+ NEXT_LOCAL_STREAM_ID.fetch_add(1, Ordering::Relaxed)
);
let path = std::env::temp_dir().join(unique);
let listener = crate::ipc::bind_local_listener(&path).unwrap();