From 3f46db01ff3a2eb80f335c63a700556e690196e4 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Joakim=20Frosteg=C3=A5rd?= Date: Wed, 6 Apr 2022 01:14:47 +0200 Subject: [PATCH] Run cargo fmt --- aquatic_http/src/workers/socket.rs | 13 ++++++++++--- aquatic_ws/src/workers/socket.rs | 13 ++++++++++--- 2 files changed, 20 insertions(+), 6 deletions(-) diff --git a/aquatic_http/src/workers/socket.rs b/aquatic_http/src/workers/socket.rs index aee1f97..5271ec0 100644 --- a/aquatic_http/src/workers/socket.rs +++ b/aquatic_http/src/workers/socket.rs @@ -485,7 +485,10 @@ fn calculate_request_consumer_index(config: &Config, info_hash: InfoHash) -> usi (info_hash.0[0] as usize) % config.request_workers } -fn create_tcp_listener(config: &Config, priv_dropper: PrivilegeDropper) -> anyhow::Result { +fn create_tcp_listener( + config: &Config, + priv_dropper: PrivilegeDropper, +) -> anyhow::Result { let domain = if config.network.address.is_ipv4() { socket2::Domain::IPV4 } else { @@ -495,10 +498,14 @@ fn create_tcp_listener(config: &Config, priv_dropper: PrivilegeDropper) -> anyho let socket = socket2::Socket::new(domain, socket2::Type::STREAM, Some(socket2::Protocol::TCP))?; if config.network.only_ipv6 { - socket.set_only_v6(true).with_context(|| "socket: set only ipv6")?; + socket + .set_only_v6(true) + .with_context(|| "socket: set only ipv6")?; } - socket.set_reuse_port(true).with_context(|| "socket: set reuse port")?; + socket + .set_reuse_port(true) + .with_context(|| "socket: set reuse port")?; socket .bind(&config.network.address.into()) diff --git a/aquatic_ws/src/workers/socket.rs b/aquatic_ws/src/workers/socket.rs index 02974cd..2da8d05 100644 --- a/aquatic_ws/src/workers/socket.rs +++ b/aquatic_ws/src/workers/socket.rs @@ -543,7 +543,10 @@ fn calculate_in_message_consumer_index(config: &Config, info_hash: InfoHash) -> (info_hash.0[0] as usize) % config.request_workers } -fn create_tcp_listener(config: &Config, priv_dropper: PrivilegeDropper) -> anyhow::Result { +fn create_tcp_listener( + config: &Config, + priv_dropper: PrivilegeDropper, +) -> anyhow::Result { let domain = if config.network.address.is_ipv4() { socket2::Domain::IPV4 } else { @@ -554,10 +557,14 @@ fn create_tcp_listener(config: &Config, priv_dropper: PrivilegeDropper) -> anyho .with_context(|| "create socket")?; if config.network.only_ipv6 { - socket.set_only_v6(true).with_context(|| "socket: set only ipv6")?; + socket + .set_only_v6(true) + .with_context(|| "socket: set only ipv6")?; } - socket.set_reuse_port(true).with_context(|| "socket: set reuse port")?; + socket + .set_reuse_port(true) + .with_context(|| "socket: set reuse port")?; socket .bind(&config.network.address.into())