diff options
| author | Kunal Mohan <kunalmohan99@gmail.com> | 2021-02-13 15:57:31 +0530 |
|---|---|---|
| committer | Kunal Mohan <kunalmohan99@gmail.com> | 2021-05-04 20:47:49 +0530 |
| commit | 75b07cc6c8639ec1ecd13d51938c91da3d76ac42 (patch) | |
| tree | 9decd33d12e94b41470ca3054d5154edcc6334a0 /src/server | |
| parent | Use interprocess crate, BufReader and BufWriter (diff) | |
| download | sl0ppij-75b07cc6c8639ec1ecd13d51938c91da3d76ac42.tar.gz sl0ppij-75b07cc6c8639ec1ecd13d51938c91da3d76ac42.tar.xz sl0ppij-75b07cc6c8639ec1ecd13d51938c91da3d76ac42.zip | |
Undo some changes
Diffstat (limited to 'src/server')
| -rw-r--r-- | src/server/mod.rs | 8 |
1 files changed, 3 insertions, 5 deletions
diff --git a/src/server/mod.rs b/src/server/mod.rs index eb87753c..95fcd715 100644 --- a/src/server/mod.rs +++ b/src/server/mod.rs @@ -110,7 +110,7 @@ pub fn start_server( command_is_executing.done_closing_pane(); } PtyInstruction::Quit => { - //break; + break; } } } @@ -146,8 +146,6 @@ pub fn start_server( } } } - - //let _ = pty_thread.join(); } }) .unwrap(); @@ -160,10 +158,10 @@ fn handle_stream( mut stream: LocalSocketStream, km: u32, ) { - //let mut reader = BufReader::new(stream); + let mut reader = BufReader::new(stream); let mut buffer = [0; 65535]; // TODO: more accurate loop { - let bytes = stream + let bytes = reader .read(&mut buffer) .expect("failed to parse ipc message"); let (mut err_ctx, decoded): (ErrorContext, ApiCommand) = |