Skip to main content

decode_shuffle_flush_flags

Function decode_shuffle_flush_flags 

Source
pub fn decode_shuffle_flush_flags(
    flags: u64,
) -> Result<(u64, bool), &'static str>
Expand description

Decode one internal clustered-shuffle flush marker into (wave, sender_activity).

ยงErrors

Rejects an untagged marker and every bit outside the internal layout. This is deliberately stricter than the general-purpose checkpoint barrier flags because shuffle-wave metadata must never be confused with source/control-plane behavior flags.