diff options
| author | Aram Drevekenin <aram@poor.dev> | 2022-09-02 15:30:43 +0200 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2022-09-02 15:30:43 +0200 |
| commit | d68d407d26edadda032fcce620316708bd9b3985 (patch) | |
| tree | 647786afce4939bc4d9c6a835ef3e35800077d44 /src | |
| parent | docs(changelog): startup router race (diff) | |
| download | sl0ppij-d68d407d26edadda032fcce620316708bd9b3985.tar.gz sl0ppij-d68d407d26edadda032fcce620316708bd9b3985.tar.xz sl0ppij-d68d407d26edadda032fcce620316708bd9b3985.zip | |
fix(router): gracefully handle client crashes (#1710)
* fix(router): gracefully handle client crashes
* style(comments): remove unused
Diffstat (limited to 'src')
| -rw-r--r-- | src/sessions.rs | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/src/sessions.rs b/src/sessions.rs index 616596ef..420ed9d1 100644 --- a/src/sessions.rs +++ b/src/sessions.rs @@ -54,7 +54,7 @@ fn assert_socket(name: &str) -> bool { match LocalSocketStream::connect(path) { Ok(stream) => { let mut sender = IpcSenderWithContext::new(stream); - sender.send(ClientToServerMsg::ConnStatus); + let _ = sender.send(ClientToServerMsg::ConnStatus); let mut receiver: IpcReceiverWithContext<ServerToClientMsg> = sender.get_receiver(); match receiver.recv() { Some((ServerToClientMsg::Connected, _)) => true, @@ -115,7 +115,7 @@ pub(crate) fn kill_session(name: &str) { let path = &*ZELLIJ_SOCK_DIR.join(name); match LocalSocketStream::connect(path) { Ok(stream) => { - IpcSenderWithContext::new(stream).send(ClientToServerMsg::KillSession); + let _ = IpcSenderWithContext::new(stream).send(ClientToServerMsg::KillSession); }, Err(e) => { eprintln!("Error occurred: {:?}", e); |