From 3ae5786e6795e14b63ae0fef1144ffc5da9f5828 Mon Sep 17 00:00:00 2001 From: Bernd Schoolmann Date: Thu, 16 Oct 2025 18:10:14 +0200 Subject: [PATCH] Clean up windows --- .../src/transport/named_pipe_listener_stream.rs | 9 +++++++-- 1 file changed, 7 insertions(+), 2 deletions(-) diff --git a/apps/desktop/desktop_native/ssh_agent/src/transport/named_pipe_listener_stream.rs b/apps/desktop/desktop_native/ssh_agent/src/transport/named_pipe_listener_stream.rs index b3e67bf621d..1d7c0abec0e 100644 --- a/apps/desktop/desktop_native/ssh_agent/src/transport/named_pipe_listener_stream.rs +++ b/apps/desktop/desktop_native/ssh_agent/src/transport/named_pipe_listener_stream.rs @@ -57,8 +57,13 @@ impl NamedPipeServerStream { } }; - let peer_info = PeerInfo::new(pid as u32, crate::transport::peer_info::PeerType::NamedPipe); - tx.send((listener, peer_info)).await.unwrap(); + let peer_info = PeerInfo::new(pid, crate::transport::peer_info::PeerType::NamedPipe); + let result = tx.send((listener, peer_info)).await; + if result.is_err() { + info!("Receiver dropped, stopping named pipe server"); + cancellation_token.cancel(); + break; + } listener = match ServerOptions::new().create(pipe_name.clone()) { Ok(pipe) => pipe,