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

Run cargo fmt

Browse source
This commit is contained in:
Joakim Frostegård 2021-10-23 12:42:56 +02:00
parent aaa609b5f0
commit 072f064138
4 changed files with 38 additions and 31 deletions
Download patch file Download diff file Expand all files Collapse all files

24
aquatic_udp/src/lib/mio/mod.rs
View file

@ -25,9 +25,9 @@ use common::State;
pub fn run(config: Config) -> ::anyhow::Result<()> {
if config.core_affinity.set_affinities {
core_affinity::set_for_current(
core_affinity::CoreId { id: config.core_affinity.offset }
);
core_affinity::set_for_current(core_affinity::CoreId {
id: config.core_affinity.offset,
});
}
let state = State::default();
@ -93,9 +93,9 @@ pub fn start_workers(
.name(format!("request-{:02}", i + 1))
.spawn(move || {
if config.core_affinity.set_affinities {
core_affinity::set_for_current(
core_affinity::CoreId { id: config.core_affinity.offset + 1 + i }
);
core_affinity::set_for_current(core_affinity::CoreId {
id: config.core_affinity.offset + 1 + i,
});
}
handlers::run_request_worker(state, config, request_receiver, response_sender)
@ -114,9 +114,9 @@ pub fn start_workers(
.name(format!("socket-{:02}", i + 1))
.spawn(move || {
if config.core_affinity.set_affinities {
core_affinity::set_for_current(
core_affinity::CoreId { id: config.core_affinity.offset + 1 + config.request_workers + i }
);
core_affinity::set_for_current(core_affinity::CoreId {
id: config.core_affinity.offset + 1 + config.request_workers + i,
});
}
network::run_socket_worker(
@ -139,9 +139,9 @@ pub fn start_workers(
.name("statistics-collector".to_string())
.spawn(move || {
if config.core_affinity.set_affinities {
core_affinity::set_for_current(
core_affinity::CoreId { id: config.core_affinity.offset }
);
core_affinity::set_for_current(core_affinity::CoreId {
id: config.core_affinity.offset,
});
}
loop {