in src/samplers/network/mod.rs [66:80]
fn spawn(common: Common) {
if common.config().samplers().network().enabled() {
if let Ok(mut sampler) = Self::new(common.clone()) {
common.runtime().spawn(async move {
loop {
let _ = sampler.sample().await;
}
});
} else if !common.config.fault_tolerant() {
fatal!("failed to initialize network sampler");
} else {
error!("failed to initialize network sampler");
}
}
}