From 9b2c5b97df63ec532d785ea19456fcccb65b6822 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Joakim=20Frosteg=C3=A5rd?= Date: Sat, 23 Jul 2022 17:35:11 +0200 Subject: [PATCH] ws: add logging in create_tcp_listener --- aquatic_ws/src/workers/socket.rs | 14 ++++++++++++++ 1 file changed, 14 insertions(+) diff --git a/aquatic_ws/src/workers/socket.rs b/aquatic_ws/src/workers/socket.rs index 6626832..61870c7 100644 --- a/aquatic_ws/src/workers/socket.rs +++ b/aquatic_ws/src/workers/socket.rs @@ -722,28 +722,42 @@ fn create_tcp_listener( socket2::Domain::IPV6 }; + ::log::info!("creating socket.."); + let socket = socket2::Socket::new(domain, socket2::Type::STREAM, Some(socket2::Protocol::TCP)) .with_context(|| "create socket")?; if config.network.only_ipv6 { + ::log::info!("setting socket to ipv6 only.."); + socket .set_only_v6(true) .with_context(|| "socket: set only ipv6")?; } + ::log::info!("setting SO_REUSEPORT on socket.."); + socket .set_reuse_port(true) .with_context(|| "socket: set reuse port")?; + ::log::info!("binding socket.."); + socket .bind(&config.network.address.into()) .with_context(|| format!("socket: bind to {}", config.network.address))?; + ::log::info!("listening on socket.."); + socket .listen(config.network.tcp_backlog) .with_context(|| format!("socket: listen {}", config.network.address))?; + ::log::info!("running PrivilegeDropper::after_socket_creation.."); + priv_dropper.after_socket_creation()?; + ::log::info!("casting socket to glommio TcpListener.."); + Ok(unsafe { TcpListener::from_raw_fd(socket.into_raw_fd()) }) }