bitwarden/browser
1
0
Fork 0
mirror of https://github.com/bitwarden/browser synced 2026-02-15 07:54:55 +00:00
Code Issues Releases Wiki Activity

Fix windows

Browse Source
This commit is contained in:
Bernd Schoolmann
2025-10-16 14:29:39 +02:00
parent e387125ccd
commit d524785376
1 changed files with 5 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
apps/desktop/desktop_native/ssh_agent/src/transport/named_pipe_listener_stream.rs
View File

@@ -24,10 +24,11 @@ impl NamedPipeServerStream {
pub async fn listen( pub async fn listen(
pipe_name: String, pipe_name: String,
agent: BitwardenDesktopAgent, agent: BitwardenDesktopAgent,
) -> Result<NamedPipeServerStream, anyhow::Error> { ) -> Result<(), anyhow::Error> {
info!("Starting SSH Named Pipe listener"); info!("Starting SSH Named Pipe listener");
let (tx, rx) = tokio::sync::mpsc::channel(16); let (tx, rx) = tokio::sync::mpsc::channel(16);
let cloned_agent = agent.clone();
tokio::spawn(async move { tokio::spawn(async move {
info!("Creating named pipe server on {}", pipe_name.clone()); info!("Creating named pipe server on {}", pipe_name.clone());
let mut listener = match ServerOptions::new().create(pipe_name.clone()) { let mut listener = match ServerOptions::new().create(pipe_name.clone()) {
@@ -37,7 +38,7 @@ impl NamedPipeServerStream {
return; return;
} }
}; };
let cancellation_token = agent.cancellation_token(); let cancellation_token = cloned_agent.cancellation_token();
loop { loop {
info!("Waiting for connection"); info!("Waiting for connection");
select! { select! {
@@ -72,7 +73,8 @@ impl NamedPipeServerStream {
} }
}); });
Ok(NamedPipeServerStream { rx }) agent.serve(NamedPipeServerStream { rx }).await;
Ok(())
} }
} }