wez/wezterm
1
1
Fork 0
mirror of https://github.com/wez/wezterm.git synced 2024-12-22 21:01:36 +03:00
Code Issues Projects Releases Wiki Activity

mux: suppress error messages when client disconnects

Browse Source
This commit is contained in:
Wez Furlong 2022-04-06 22:23:42 -07:00
parent ad91e37768
commit b70ca55bdb
1 changed files with 34 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

40
wezterm-mux-server-impl/src/dispatch.rs
View File

@ -68,15 +68,43 @@ where
match smol::future::or(rx_msg, wait_for_read).await {
Ok(Item::Readable) => {
let decoded = Pdu::decode_async(&mut stream).await?;
let decoded = match Pdu::decode_async(&mut stream).await {
Ok(data) => data,
Err(err) => {
if let Some(err) = err.root_cause().downcast_ref::<std::io::Error>() {
if err.kind() == std::io::ErrorKind::UnexpectedEof {
// Client disconnected: no need to make a noise
return Ok(());
}
}
return Err(err).context("reading Pdu from client");
}
};
handler.process_one(decoded);
}
Ok(Item::WritePdu(decoded)) => {
decoded
.pdu
.encode_async(&mut stream, decoded.serial)
.await?;
stream.flush().await.context("flushing PDU to client")?;
match decoded.pdu.encode_async(&mut stream, decoded.serial).await {
Ok(()) => {}
Err(err) => {
if let Some(err) = err.root_cause().downcast_ref::<std::io::Error>() {
if err.kind() == std::io::ErrorKind::BrokenPipe {
// Client disconnected: no need to make a noise
return Ok(());
}
}
return Err(err).context("encoding PDU to client");
}
};
match stream.flush().await {
Ok(()) => {}
Err(err) => {
if err.kind() == std::io::ErrorKind::BrokenPipe {
// Client disconnected: no need to make a noise
return Ok(());
}
return Err(err).context("flushing PDU to client");
}
}
}
Ok(Item::Notif(MuxNotification::PaneOutput(pane_id))) => {
handler.schedule_pane_push(pane_id);