diff --git a/crates/udp/Cargo.toml b/crates/udp/Cargo.toml index d873087..d6176c7 100644 --- a/crates/udp/Cargo.toml +++ b/crates/udp/Cargo.toml @@ -23,8 +23,6 @@ default = ["prometheus", "mimalloc"] prometheus = ["metrics", "aquatic_common/prometheus"] # Experimental io_uring support (Linux 6.0 or later required) io-uring = ["dep:io-uring"] -# Experimental CPU pinning support -cpu-pinning = ["aquatic_common/cpu-pinning"] # Use mimalloc allocator for much better performance. # # Requires cmake and a C compiler diff --git a/crates/udp_load_test/src/lib.rs b/crates/udp_load_test/src/lib.rs index fced2ca..83fe463 100644 --- a/crates/udp_load_test/src/lib.rs +++ b/crates/udp_load_test/src/lib.rs @@ -5,8 +5,6 @@ use std::sync::{atomic::Ordering, Arc}; use std::thread::{self, Builder}; 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_udp_protocol::{InfoHash, Port}; use crossbeam_channel::{unbounded, Receiver}; @@ -67,26 +65,10 @@ pub fn run(config: Config) -> ::anyhow::Result<()> { let statistics_sender = statistics_sender.clone(); 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) })?; } - #[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); Ok(())