in http/get_simple/rs/server/src/main.rs [107:135]
fn main() -> Result<()> {
// Configure tracing subscriber.
tracing_subscriber::fmt()
.with_span_events(FmtSpan::CLOSE)
.init();
// Generate random data.
let _ = Lazy::force(&DATA);
// Start listening.
let bind_addr = SocketAddr::new(IpAddr::V4(Ipv4Addr::LOCALHOST), 8008);
let listener = TcpListener::bind(bind_addr)?;
info!(%bind_addr, "Listening");
// Handle incoming connections.
loop {
match listener.accept() {
Ok((stream, remote_peer)) => {
thread::spawn(move || {
info_span!("Writing Arrow IPC stream", %remote_peer)
.in_scope(|| get_simple(stream))
});
}
Err(error) => {
error!(%error, "Connection failed");
}
}
}
}