Skip to main content

drain_pending_barriers

risingwave_meta::barrier::checkpoint::independent_job::creating_job::status

Function drain_pending_barriers 

Source 
fn drain_pending_barriers(
    pending_barriers: &mut VecDeque<BarrierInfo>,
    new_upstream_barrier: BarrierInfo,
    barrier_num_to_inject: usize,
) -> Vec<BarrierInfo>