32 lines
950 B
Rust
32 lines
950 B
Rust
use anyhow::Result;
|
|
use tokio::net::TcpListener;
|
|
use tracing::Instrument;
|
|
|
|
use crate::log_error;
|
|
|
|
use super::NetworkSession;
|
|
|
|
pub async fn listen(bind_addr: &str) -> Result<()> {
|
|
let listener = TcpListener::bind(bind_addr).await?;
|
|
tracing::info!("Listening at {bind_addr}");
|
|
|
|
loop {
|
|
let Ok((client_socket, client_addr)) = listener.accept().await else {
|
|
continue;
|
|
};
|
|
|
|
tracing::info!("New session from {client_addr}");
|
|
|
|
let mut session = NetworkSession::new(client_socket, client_addr);
|
|
tokio::spawn(
|
|
async move {
|
|
log_error!(
|
|
"Session from {client_addr} disconnected",
|
|
format!("An error occurred while processing session ({client_addr})"),
|
|
Box::pin(session.run()).await
|
|
);
|
|
}
|
|
.instrument(tracing::info_span!("session", addr = %client_addr)),
|
|
);
|
|
}
|
|
}
|