to_tcp_listener() is essentially useless

pull/12/head
Frank Denis 5 years ago
parent 6483d3d4d7
commit e43ad4949b

@ -392,20 +392,25 @@ fn bind_listeners(
for listen_addr in listen_addrs {
let std_socket = match listen_addr {
SocketAddr::V4(_) => net2::TcpBuilder::new_v4()?
.reuse_address(true)?
.bind(&listen_addr)?
.to_tcp_listener()?,
.listen(1024)?,
SocketAddr::V6(_) => net2::TcpBuilder::new_v6()?
.reuse_address(true)?
.only_v6(true)?
.bind(&listen_addr)?
.to_tcp_listener()?,
.listen(1024)?,
};
let tcp_listener = match TcpListener::from_std(std_socket, &Default::default()) {
Ok(tcp_listener) => tcp_listener,
Err(e) => bail!(format_err!("{}/TCP: {}", listen_addr, e)),
};
let std_socket = match listen_addr {
SocketAddr::V4(_) => net2::UdpBuilder::new_v4()?.bind(&listen_addr),
SocketAddr::V4(_) => net2::UdpBuilder::new_v4()?
.reuse_address(true)?
.bind(&listen_addr),
SocketAddr::V6(_) => net2::UdpBuilder::new_v6()?
.reuse_address(true)?
.only_v6(true)?
.bind(&listen_addr),
};

@ -55,12 +55,14 @@ pub async fn prometheus_service(
let path = Arc::new(metrics_config.path);
let std_socket = match metrics_config.listen_addr {
SocketAddr::V4(_) => net2::TcpBuilder::new_v4()?
.reuse_address(true)?
.bind(&metrics_config.listen_addr)?
.to_tcp_listener()?,
.listen(1024)?,
SocketAddr::V6(_) => net2::TcpBuilder::new_v6()?
.reuse_address(true)?
.only_v6(true)?
.bind(&metrics_config.listen_addr)?
.to_tcp_listener()?,
.listen(1024)?,
};
let mut stream = TcpListener::from_std(std_socket, &Default::default())?;
let concurrent_connections = Arc::new(AtomicU32::new(0));

Loading…
Cancel
Save