From c1bab5808b993d33bc505196f58b215d368c8e27 Mon Sep 17 00:00:00 2001 From: Quentin Dufour Date: Wed, 24 Jan 2024 17:50:03 +0100 Subject: [PATCH] QoL connection management --- src/auth.rs | 24 +++++++++++++++++++----- 1 file changed, 19 insertions(+), 5 deletions(-) diff --git a/src/auth.rs b/src/auth.rs index 42b3362..52b6fab 100644 --- a/src/auth.rs +++ b/src/auth.rs @@ -82,7 +82,7 @@ impl AuthServer { }; tracing::info!("AUTH: accepted connection from {}", remote_addr); - let conn = tokio::spawn(NetLoop::new(socket).run_error()); + let conn = tokio::spawn(NetLoop::new(socket, must_exit.clone()).run_error()); connections.push(conn); @@ -98,12 +98,14 @@ impl AuthServer { struct NetLoop { stream: BufStream, + stop: watch::Receiver, } impl NetLoop { - fn new(stream: TcpStream) -> Self{ + fn new(stream: TcpStream, stop: watch::Receiver) -> Self { Self { stream: BufStream::new(stream), + stop, } } @@ -118,9 +120,21 @@ impl NetLoop { let mut buff: Vec = Vec::new(); loop { buff.clear(); - self.stream.read_until(b'\n', &mut buff).await?; - let (input, cmd) = client_command(&buff).map_err(|_| anyhow!("Unable to parse command"))?; - println!("input: {:?}, cmd: {:?}", input, cmd); + tokio::select! { + read_res = self.stream.read_until(b'\n', &mut buff) => { + let bread = read_res?; + if bread == 0 { + tracing::info!("Reading buffer empty, connection has been closed. Exiting AUTH session."); + return Ok(()) + } + let (input, cmd) = client_command(&buff).map_err(|_| anyhow!("Unable to parse command"))?; + println!("input: {:?}, cmd: {:?}", input, cmd); + }, + _ = self.stop.changed() => { + tracing::debug!("Server is stopping, quitting this runner"); + return Ok(()) + } + } } } }