Skip to main content

send_start_instructions

Function send_start_instructions 

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

Builds Start instruction for all participating workers. Sends them for measurement init, and persists them for re-joining workers.