From b05cbc563d77be4b3ecde6d8164fa619cc232b4b Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Joakim=20Frosteg=C3=A5rd?= <joakim.frostegard@gmail.com>
Date: Sun, 7 Nov 2021 15:10:39 +0100
Subject: [PATCH] udp load test: fix cpu pinning issue

---
 aquatic_udp_load_test/src/main.rs | 12 ++++++------
 1 file changed, 6 insertions(+), 6 deletions(-)

diff --git a/aquatic_udp_load_test/src/main.rs b/aquatic_udp_load_test/src/main.rs
index 261cc5a..ecc0b46 100644
--- a/aquatic_udp_load_test/src/main.rs
+++ b/aquatic_udp_load_test/src/main.rs
@@ -46,12 +46,6 @@ fn run(config: Config) -> ::anyhow::Result<()> {
 
     println!("Starting client with config: {:#?}", config);
 
-    pin_current_if_configured_to(
-        &config.cpu_pinning,
-        config.num_socket_workers as usize,
-        WorkerIndex::Other,
-    );
-
     let mut info_hashes = Vec::with_capacity(config.handler.number_of_torrents);
 
     for _ in 0..config.handler.number_of_torrents {
@@ -138,6 +132,12 @@ fn run(config: Config) -> ::anyhow::Result<()> {
             .expect("bootstrap: add initial request to request queue");
     }
 
+    pin_current_if_configured_to(
+        &config.cpu_pinning,
+        config.num_socket_workers as usize,
+        WorkerIndex::Other,
+    );
+
     monitor_statistics(state, &config);
 
     Ok(())