Function encode_rle

nodedb-array/src/codec/coord_rle.rs:61–94

(dict: &DimDict, out: &mut Vec<u8>)

}

fn encode_rle(dict: &DimDict, out: &mut Vec<u8>) -> ArrayResult<()> {
    out.extend_from_slice(&RLE_MARKER.to_le_bytes());

    // Compute runs over index stream.
    let mut runs: Vec<(u32, u32)> = Vec::new(); // (value, length)
    let mut i = 0;
    while i < dict.indices.len() {
        let val = dict.indices[i];
        let mut len = 1u32;
        while i + (len as usize) < dict.indices.len() && dict.indices[i + (len as usize)] == val {
            len += 1;
        }
        runs.push((val, len));
        i += len as usize;
    }

    out.extend_from_slice(&(runs.len() as u32).to_le_bytes());
    for (val, len) in &runs {
        out.extend_from_slice(&val.to_le_bytes());
        out.extend_from_slice(&len.to_le_bytes());
    }

    // Dict values.
    out.extend_from_slice(&(dict.values.len() as u32).to_le_bytes());
    for cv in &dict.values {
        let bytes = zerompk::to_msgpack_vec(cv).map_err(|e| ArrayError::SegmentCorruption {
            detail: format!("rle coord dict encode: {e}"),
        })?;
        out.extend_from_slice(&(bytes.len() as u32).to_le_bytes());
        out.extend_from_slice(&bytes);
    }

    Ok(())
}

/// Decode a DimDict from bytes previously encoded by `encode_coord_axis_rle`.
pub fn decode_coord_axis_rle(data: &[u8], pos: &mut usize) -> ArrayResult<DimDict> {