use super::ScenarioConfig;
use crate::stats::RunStatistics;
use crate::tps_sampler::TpsSampler;
use humantime::format_duration;
use std::future::Future;
use std::num::NonZeroU32;
#[allow(unused_imports)]
use std::time::{Duration, Instant};
#[allow(unused_imports)]
use tracing::{debug, error, info, instrument, trace, warn, Instrument};
#[instrument(name="scenario", skip_all, fields(name=config.name))]
pub(crate) async fn run_direct<T, F>(scenario: T, config: ScenarioConfig) -> RunStatistics
where
T: Fn() -> F + Send + Sync + 'static + Clone,
F: Future<Output = ()> + Send,
{
info!("Running {} with config {:?}", config.name, &config);
let start = Instant::now();
let (goal_tps, concurrency) = config.direct().unwrap();
let goal_tps = NonZeroU32::new(goal_tps).unwrap();
let mut sampler = TpsSampler::new(scenario, goal_tps);
sampler.set_concurrent_count(concurrency);
loop {
let sample = sampler.sample_tps().await;
info!(
"Sample: {:.2}TPS, {}/{} ({}), {}",
sample.tps(),
sample.success_count,
sample.error_count,
sample.total(),
format_duration(sample.elapsed),
);
if start.elapsed() > config.duration {
break;
}
}
sampler.wait_for_shutdown().await;
info!("Scenario complete");
RunStatistics {
concurrency,
goal_tps,
stable: true,
}
}