YGGverse/aquatic
1
0
Fork 0
mirror of https://github.com/YGGverse/aquatic.git synced 2026-03-31 09:45:31 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

ws: add logging in create_tcp_listener

Browse source
This commit is contained in:
Joakim Frostegård 2022-07-23 17:35:11 +02:00
parent 38e74bfc20
commit 9b2c5b97df
1 changed files with 14 additions and 0 deletions
Download patch file Download diff file Expand all files Collapse all files

14
aquatic_ws/src/workers/socket.rs
View file

@ -722,28 +722,42 @@ fn create_tcp_listener(
socket2::Domain::IPV6 socket2::Domain::IPV6
}; };
::log::info!("creating socket..");
let socket = socket2::Socket::new(domain, socket2::Type::STREAM, Some(socket2::Protocol::TCP)) let socket = socket2::Socket::new(domain, socket2::Type::STREAM, Some(socket2::Protocol::TCP))
.with_context(|| "create socket")?; .with_context(|| "create socket")?;
if config.network.only_ipv6 { if config.network.only_ipv6 {
::log::info!("setting socket to ipv6 only..");
socket socket
.set_only_v6(true) .set_only_v6(true)
.with_context(|| "socket: set only ipv6")?; .with_context(|| "socket: set only ipv6")?;
} }
::log::info!("setting SO_REUSEPORT on socket..");
socket socket
.set_reuse_port(true) .set_reuse_port(true)
.with_context(|| "socket: set reuse port")?; .with_context(|| "socket: set reuse port")?;
::log::info!("binding socket..");
socket socket
.bind(&config.network.address.into()) .bind(&config.network.address.into())
.with_context(|| format!("socket: bind to {}", config.network.address))?; .with_context(|| format!("socket: bind to {}", config.network.address))?;
::log::info!("listening on socket..");
socket socket
.listen(config.network.tcp_backlog) .listen(config.network.tcp_backlog)
.with_context(|| format!("socket: listen {}", config.network.address))?; .with_context(|| format!("socket: listen {}", config.network.address))?;
::log::info!("running PrivilegeDropper::after_socket_creation..");
priv_dropper.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()) }) Ok(unsafe { TcpListener::from_raw_fd(socket.into_raw_fd()) })
} }