gruberb/protohackers
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Debugging race condition

Browse source
This commit is contained in:
Bastian Gruber 2023-05-03 08:13:55 +02:00
parent 5122ef3fe8
commit 9c77c7f5d7
No known key found for this signature in database
GPG key ID: BE9F8C772B188CBF
1 changed files with 12 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

16
problem_05/bin/server.rs
View file

@ -47,12 +47,13 @@ pub async fn handle_request(socket: TcpStream, upstream: TcpStream) -> Result<()
let mut framed_client_write = FramedWrite::new(client_write, LinesCodec::new()); let mut framed_client_write = FramedWrite::new(client_write, LinesCodec::new());
let (server_read, server_write) = upstream.into_split(); let (server_read, server_write) = upstream.into_split();
let mut farmed_server_read = FramedRead::new(server_read, LinesCodec::new()); let mut framed_server_read = FramedRead::new(server_read, LinesCodec::new());
let mut framed_server_write = FramedWrite::new(server_write, LinesCodec::new()); let mut framed_server_write = FramedWrite::new(server_write, LinesCodec::new());
loop { loop {
tokio::select! { tokio::select! {
res = framed_client_read.next() => { res = framed_client_read.next() => {
info!("Response from client read: {:?}", res);
match res { match res {
Some(response) => { Some(response) => {
match response { match response {
@ -66,10 +67,14 @@ pub async fn handle_request(socket: TcpStream, upstream: TcpStream) -> Result<()
} }
} }
} }
None => return Ok(()) None => {
info!("Client closed the connection");
return Ok(())
}
} }
} }
res = farmed_server_read.next() => { res = framed_server_read.next() => {
info!("Response from server read: {:?}", res);
match res { match res {
Some(response) => { Some(response) => {
match response { match response {
@ -83,7 +88,10 @@ pub async fn handle_request(socket: TcpStream, upstream: TcpStream) -> Result<()
} }
} }
} }
None => return Ok(()) None => {
info!("Server closed the connection");
return Ok(())
}
} }
} }
} }