vyre-runtime 0.6.3

//! Shared fallible staging reservations for megakernel host-side runtime paths.

use crate::PipelineError;
use std::collections::HashMap;
use std::hash::{BuildHasher, Hash};
use vyre_driver::reservation_policy::ReservationPolicy;

const MEGAKERNEL_STAGING: ReservationPolicy = ReservationPolicy::new(
    "megakernel runtime staging",
    "split the megakernel workload or reuse caller-owned staging",
);

pub(super) fn try_reserve_vec_capacity<T>(
    values: &mut Vec<T>,
    capacity: usize,
) -> Result<(), String> {
    MEGAKERNEL_STAGING
        .reserve_vec_to_capacity(values, capacity, "element")
        .map_err(|source| source.to_string())
}

pub(super) fn reserve_vec_capacity<T>(
    values: &mut Vec<T>,
    capacity: usize,
    label: &'static str,
) -> Result<(), PipelineError> {
    MEGAKERNEL_STAGING
        .reserve_vec_to_capacity(values, capacity, label)
        .map_err(|source| {
            PipelineError::Backend(format!(
                "megakernel {label} reservation failed for {capacity} element(s): {source}"
            ))
        })
}

pub(super) fn reserve_hash_map_capacity<K, V, S>(
    values: &mut HashMap<K, V, S>,
    capacity: usize,
    label: &'static str,
) -> Result<(), PipelineError>
where
    K: Eq + Hash,
    S: BuildHasher,
{
    MEGAKERNEL_STAGING
        .reserve_hash_map_to_capacity(values, capacity, label)
        .map_err(|source| {
            PipelineError::Backend(format!(
                "megakernel {label} reservation failed for {capacity} entry(s): {source}"
            ))
        })
}

#[cfg(test)]
mod tests {
    use super::*;

    #[test]
    fn reserve_vec_capacity_grows_after_clear() {
        let mut values = Vec::<u32>::with_capacity(4);
        values.extend_from_slice(&[1, 2, 3, 4]);
        values.clear();
        reserve_vec_capacity(&mut values, 8, "test vector")
            .expect("Fix: replace expect with fallible API or document caller precondition; panic only on programmer error - cleared vector should grow to target capacity");
        assert!(values.capacity() >= 8);
        assert!(values.is_empty());
    }

    #[test]
    fn reserve_vec_capacity_reports_context_on_overflow() {
        let mut values = Vec::<u8>::new();
        let err = reserve_vec_capacity(&mut values, usize::MAX, "huge telemetry")
            .expect_err("oversized reservation should fail");
        let message = err.to_string();
        assert!(message.contains("huge telemetry"));
        assert!(message.contains("Fix:"));
    }

    #[test]
    fn reserve_hash_map_capacity_uses_shared_policy_and_preserves_entries() {
        let mut values = HashMap::<u32, u32>::new();
        values.insert(7, 11);

        reserve_hash_map_capacity(&mut values, 32, "test map")
            .expect("Fix: replace expect with fallible API or document caller precondition; panic only on programmer error - hash map reservation should use shared staging policy");

        assert_eq!(values.get(&7), Some(&11));
        assert!(values.capacity() >= 32);
    }

    #[test]
    fn runtime_staging_reserve_delegates_to_backend_neutral_policy() {
        let source = include_str!("staging_reserve.rs");

        assert!(source.contains("ReservationPolicy::new"));
        assert!(source.contains("reserve_vec_to_capacity"));
        assert!(source.contains("reserve_hash_map_to_capacity"));
        assert!(
            !source.contains(concat!(
                "vyre_foundation::allocation::",
                "try_reserve_vec_to_capacity"
            ))
                && !source.contains(concat!(
                    "vyre_foundation::allocation::",
                    "try_reserve_hash_map_to_capacity"
                )),
            "Fix: megakernel runtime staging must use the backend-neutral reservation policy instead of carrying a parallel allocation adapter."
        );
    }
}