diff --git a/examples/benchmark.rs b/examples/benchmark.rs index 21247e6..df8d313 100644 --- a/examples/benchmark.rs +++ b/examples/benchmark.rs @@ -61,11 +61,10 @@ async fn main() -> Result<(), Box> { let mut sessions = JoinSet::new(); let mut reports = Vec::new(); let mut spawned_sessions = 0usize; - let mut next_session_id = 1usize; spawn_session( &mut sessions, - next_session_id, + spawned_sessions, Arc::clone(&model), license.clone(), config.clone(), @@ -85,10 +84,9 @@ async fn main() -> Result<(), Box> { let first_failed_report = loop { tokio::select! { _ = spawn_ticks.tick() => { - next_session_id += 1; spawn_session( &mut sessions, - next_session_id, + spawned_sessions, Arc::clone(&model), license.clone(), config.clone(), @@ -188,7 +186,7 @@ async fn main() -> Result<(), Box> { fn spawn_session( sessions: &mut JoinSet, - session_id: usize, + previous_session_id: usize, model: Arc>, license: String, config: ProcessorConfig, @@ -197,7 +195,7 @@ fn spawn_session( stop: Arc, ) { sessions.spawn(run_session( - session_id, + previous_session_id + 1, model, license, config,