pezkuwichain/pezkuwi-telemetry
1
0
Fork 0
mirror of https://github.com/pezkuwichain/pezkuwi-telemetry.git synced 2026-06-14 00:21:01 +00:00
Code Issues Packages Projects Releases Wiki Activity

test runner: fix soak test for multiple ids per ndoe

Browse Source
This commit is contained in:
James Wilson
2021-08-10 11:54:14 +01:00
parent 20463ce159
commit f72f8c1fd5
1 changed files with 8 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files
backend/telemetry_core/tests/soak_tests.rs
+8 -6
View File
@@ -119,10 +119,12 @@ async fn run_realistic_soak_test(opts: SoakTestOpts) {
let bytes_in = Arc::new(AtomicUsize::new(0)); let bytes_in = Arc::new(AtomicUsize::new(0));
let ids_per_node = opts.ids_per_node; let ids_per_node = opts.ids_per_node;
for node in nodes.into_iter().enumerate() { for node in nodes.into_iter().enumerate() {
let bytes_in = Arc::clone(&bytes_in); let (idx, (tx, _)) = node;
tokio::spawn(async move { for id in 0..ids_per_node {
let (idx, (tx, _)) = node; let bytes_in = Arc::clone(&bytes_in);
for id in 0..ids_per_node { let tx = tx.clone();
tokio::spawn(async move {
let telemetry = test_utils::fake_telemetry::FakeTelemetry::new( let telemetry = test_utils::fake_telemetry::FakeTelemetry::new(
Duration::from_secs(3), Duration::from_secs(3),
format!("Node {}", idx + 1), format!("Node {}", idx + 1),
@@ -141,8 +143,8 @@ async fn run_realistic_soak_test(opts: SoakTestOpts) {
if let Err(e) = res { if let Err(e) = res {
log::error!("Telemetry Node #{} has died with error: {}", idx, e); log::error!("Telemetry Node #{} has died with error: {}", idx, e);
} }
} });
}); }
} }
// Connect feeds to the core: // Connect feeds to the core: