- // The second item contains the IP and port of the new connection
- let (socket, addr) = listener.accept().await.unwrap();
- log::debug!("got connection from {:?}", addr);
- let db_i = db.clone();
- tokio::spawn(async move { process(socket, db_i).await });
+ match listener.accept().await {
+ Ok((socket, addr)) => {
+ log::debug!("got connection from {:?}", addr);
+ let db_i = db.clone();
+ tokio::spawn(async move {
+ if let Err(e) = process(socket, db_i).await {
+ log::warn!("failed: {:?}", e);
+ }
+ });
+ },
+ Err(e) => log::warn!("Failed to accept connection: {}", e),
+ };