From ddf8e1ceb13ffd4e4afc57c2ecff633f6661b598 Mon Sep 17 00:00:00 2001 From: Bastian Gruber Date: Mon, 1 May 2023 09:29:40 +0000 Subject: [PATCH] Add tracing --- problem_04/bin/server.rs | 9 ++++++++- 1 file changed, 8 insertions(+), 1 deletion(-) diff --git a/problem_04/bin/server.rs b/problem_04/bin/server.rs index 0d72cb8..77305d0 100644 --- a/problem_04/bin/server.rs +++ b/problem_04/bin/server.rs @@ -2,16 +2,22 @@ use std::collections::HashMap; use std::sync::Mutex; use std::{io, net::SocketAddr, str, sync::Arc}; use tokio::{net::UdpSocket, sync::mpsc}; +use tracing::info; #[tokio::main] async fn main() -> io::Result<()> { - let sock = UdpSocket::bind("0.0.0.0:8080".parse::().unwrap()).await?; + tracing_subscriber::fmt::try_init().unwrap(); + + let sock = UdpSocket::bind("0.0.0.0:1222".parse::().unwrap()).await?; + info!("listening to new connections"); + let r = Arc::new(sock); let s = r.clone(); let (tx, mut rx) = mpsc::channel::<(Vec, SocketAddr)>(1_000); let storage = Arc::new(Mutex::new(HashMap::::new())); tokio::spawn(async move { + info!("Send back!"); while let Some((bytes, addr)) = rx.recv().await { let _ = s.send_to(&bytes, &addr).await.unwrap(); } @@ -19,6 +25,7 @@ async fn main() -> io::Result<()> { let mut buf = [0; 1024]; loop { + info!("Recv loop"); let (len, addr) = r.recv_from(&mut buf).await?; let message = str::from_utf8(&buf[..len]).unwrap().trim_matches('\n');