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

Pass problem_04

Browse source
This commit is contained in:
Bastian Gruber 2023-05-01 10:01:27 +00:00
parent 2faa3e4271
commit cda9d2e2a3
1 changed files with 2 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

6
problem_04/bin/server.rs
View file

@ -17,7 +17,6 @@ async fn main() -> io::Result<()> {
let storage = Arc::new(Mutex::new(HashMap::<String, String>::new())); let storage = Arc::new(Mutex::new(HashMap::<String, String>::new()));
tokio::spawn(async move { tokio::spawn(async move {
info!("Send back!");
while let Some((bytes, addr)) = rx.recv().await { while let Some((bytes, addr)) = rx.recv().await {
let _ = s.send_to(&bytes, &addr).await.unwrap(); let _ = s.send_to(&bytes, &addr).await.unwrap();
} }
@ -25,10 +24,9 @@ async fn main() -> io::Result<()> {
let mut buf = [0; 1024]; let mut buf = [0; 1024];
loop { loop {
info!("Recv loop");
let (len, addr) = r.recv_from(&mut buf).await?; let (len, addr) = r.recv_from(&mut buf).await?;
let message = str::from_utf8(&buf[..len]).unwrap().trim_matches('\n'); let message = str::from_utf8(&buf[..len]).unwrap();
info!("Message: {message}");
if message.contains("version") { if message.contains("version") {
let message = format!("version=gruberb 1.0"); let message = format!("version=gruberb 1.0");
tx.send((message.as_bytes().to_vec(), addr)).await.unwrap(); tx.send((message.as_bytes().to_vec(), addr)).await.unwrap();