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

Fully remove udp cpu pinning support

Browse source
This commit is contained in:
Joakim Frostegård 2024-05-03 22:49:20 +02:00
parent 215a22c95b
commit 19df20e03f
2 changed files with 0 additions and 20 deletions
Download patch file Download diff file Expand all files Collapse all files

2
crates/udp/Cargo.toml
View file

@ -23,8 +23,6 @@ default = ["prometheus", "mimalloc"]
prometheus = ["metrics", "aquatic_common/prometheus"] prometheus = ["metrics", "aquatic_common/prometheus"]
# Experimental io_uring support (Linux 6.0 or later required) # Experimental io_uring support (Linux 6.0 or later required)
io-uring = ["dep:io-uring"] io-uring = ["dep:io-uring"]
# Experimental CPU pinning support
cpu-pinning = ["aquatic_common/cpu-pinning"]
# Use mimalloc allocator for much better performance. # Use mimalloc allocator for much better performance.
# #
# Requires cmake and a C compiler # Requires cmake and a C compiler

18
crates/udp_load_test/src/lib.rs
View file

@ -5,8 +5,6 @@ use std::sync::{atomic::Ordering, Arc};
use std::thread::{self, Builder}; use std::thread::{self, Builder};
use std::time::{Duration, Instant}; use std::time::{Duration, Instant};
#[cfg(feature = "cpu-pinning")]
use aquatic_common::cpu_pinning::{pin_current_if_configured_to, WorkerIndex};
use aquatic_common::IndexMap; use aquatic_common::IndexMap;
use aquatic_udp_protocol::{InfoHash, Port}; use aquatic_udp_protocol::{InfoHash, Port};
use crossbeam_channel::{unbounded, Receiver}; use crossbeam_channel::{unbounded, Receiver};
@ -67,26 +65,10 @@ pub fn run(config: Config) -> ::anyhow::Result<()> {
let statistics_sender = statistics_sender.clone(); let statistics_sender = statistics_sender.clone();
Builder::new().name("load-test".into()).spawn(move || { Builder::new().name("load-test".into()).spawn(move || {
#[cfg(feature = "cpu-pinning")]
pin_current_if_configured_to(
&config.cpu_pinning,
config.workers as usize,
0,
WorkerIndex::SocketWorker(i as usize),
);
Worker::run(config, state, statistics_sender, peers, addr) Worker::run(config, state, statistics_sender, peers, addr)
})?; })?;
} }
#[cfg(feature = "cpu-pinning")]
pin_current_if_configured_to(
&config.cpu_pinning,
config.workers as usize,
0,
WorkerIndex::Util,
);
monitor_statistics(state, &config, statistics_receiver); monitor_statistics(state, &config, statistics_receiver);
Ok(()) Ok(())