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

Run cargo fmt

Browse source
This commit is contained in:
Joakim Frostegård 2022-04-06 01:14:47 +02:00
parent d0eec05d4c
commit 3f46db01ff
2 changed files with 20 additions and 6 deletions
Download patch file Download diff file Expand all files Collapse all files

13
aquatic_http/src/workers/socket.rs
View file

@ -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<TcpListener> {
fn create_tcp_listener(
config: &Config,
priv_dropper: PrivilegeDropper,
) -> anyhow::Result<TcpListener> {
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())

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

@ -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<TcpListener> {
fn create_tcp_listener(
config: &Config,
priv_dropper: PrivilegeDropper,
) -> anyhow::Result<TcpListener> {
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())