Removing affinity code.

hydro-project · Dec 6, 2024 · 988cd03 · 988cd03
1 parent 90320b4
commit 988cd03
Show file tree

Hide file tree

Showing 3 changed files with 0 additions and 27 deletions.
diff --git a/Cargo.lock b/Cargo.lock
diff --git a/datastores/gossip_kv/Cargo.toml b/datastores/gossip_kv/Cargo.toml
@@ -7,7 +7,6 @@ license = "Apache-2.0"
 publish = false
 
 [dependencies]
-affinity = "0.1.2"
 clap = { version = "4.5.4", features = ["derive", "env"] }
 config = "0.14.0"
 governor = "0.7.0"

diff --git a/datastores/gossip_kv/load_test_server/server.rs b/datastores/gossip_kv/load_test_server/server.rs
@@ -2,7 +2,6 @@ use std::convert::Infallible;
 use std::num::{NonZeroU32, ParseFloatError};
 use std::thread::sleep;
 use std::time::Duration;
-use affinity::set_thread_affinity;
 use clap::Parser;
 use gossip_kv::membership::{MemberDataBuilder, Protocol};
 use gossip_kv::{ClientRequest, GossipMessage, Key};
@@ -65,7 +64,6 @@ fn run_server(
     let (client_input_tx, client_input_rx) = bounded_channel(1000);
 
     std::thread::spawn(move || {
-        set_thread_affinity([0]).unwrap();
 
         let rt = tokio::runtime::Builder::new_current_thread()
             .enable_all()
@@ -122,7 +120,6 @@ fn run_server(
     });
 
     std::thread::spawn(move || {
-        set_thread_affinity([2]).unwrap();
         let rt = tokio::runtime::Builder::new_current_thread()
             .enable_all()
             .build()