in src/samplers/xfs/mod.rs [60:74]
fn spawn(common: Common) {
if common.config().samplers().xfs().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 xfs sampler");
} else {
error!("failed to initialize xfs sampler");
}
}
}