INNER CODE UNIT · Rust

destroy_jobs

lanterndata/lantern · lantern_cli/src/daemon/mod.rs:75

async fn destroy_jobs(target_db: &TargetDB, logger: Arc<Logger>) {
    logger.info(&format!("Destroying tasks for {}", target_db.name));
    let mut jobs = JOBS.write().await;
    let cancel_token = jobs.remove(&target_db.name);

    if cancel_token.is_none() {
        return;
    }

    let cancel_token = cancel_token.unwrap();

    cancel_token.cancel();
}

async fn spawn_job(
    target_db: Arc<TargetDB>,
    args: Arc<cli::DaemonArgs>,
    job_type: JobType,

View source record →