Skip to main content

finalize_measurement

manycastr::orchestrator::task_distributor

Function finalize_measurement 

Source 
async fn finalize_measurement(
    workers: &Arc<Mutex<Vec<WorkerSender<Result<Instruction, Status>>>>>,
    measurement: &Arc<RwLock<Option<MeasurementState>>>,
    m_id: u32,
)
Expand description

Finalize a measurement once task distribution is done: send the end-of-measurement instruction to all workers (marking them finished), then wait for every worker to report back before the distributor task exits.

Does nothing when measurement m_id is no longer the active one (the CLI dropped and tore it down, possibly replacing it with a new measurement in the meantime).