fn collect()

in netbench-collector/src/generic.rs [55:69]


fn collect(mut proc: Proc, interval: Duration, is_open: Arc<AtomicBool>) {
    let mut stats = Stats::default();

    loop {
        proc.load(&mut stats);
        stats.print().unwrap();

        if !is_open.load(Ordering::Relaxed) {
            return;
        }

        std::thread::sleep(interval);
        stats.time += interval;
    }
}