fn spawn()

in src/samplers/ntp/mod.rs [40:56]

• 17 lines of code
• 5 McCabe index (conditional complexity)

    fn spawn(common: Common) {
        debug!("spawning");
        if common.config().samplers().ntp().enabled() {
            debug!("sampler is enabled");
            if let Ok(mut ntp) = Ntp::new(common.clone()) {
                common.runtime().spawn(async move {
                    loop {
                        let _ = ntp.sample().await;
                    }
                });
            } else if !common.config.fault_tolerant() {
                fatal!("failed to initialize ntp sampler");
            } else {
                error!("failed to initialize ntp sampler");
            }
        }
    }