subms-block-cache 0.5.2

//! `SubMsRecipe` impl.

use subms::{
    SubMsBenchParams, SubMsLcg, SubMsPerfHarness, SubMsRecipe, SubMsStageKind, SubMsTimer,
};

use crate::BlockCache;

pub struct BlockCacheRecipe;

impl SubMsRecipe for BlockCacheRecipe {
    fn name(&self) -> &str {
        "block-cache"
    }

    fn run(&self, h: &mut SubMsPerfHarness, params: &SubMsBenchParams) {
        let entries = params.entries;
        let warmup = params.warmup;
        let seed = params.seed;
        let cap = 1024;
        let mut c: BlockCache<u32, u32> = BlockCache::with_capacity(cap);

        let mut rng = SubMsLcg::new(seed);
        for _ in 0..warmup {
            let k = rng.bounded((cap * 2) as u32);
            c.put(k, k);
        }

        let s_get = h.stage("get", entries).with_kind(SubMsStageKind::HotPath);
        let mut rng = SubMsLcg::new(seed.wrapping_add(1));
        for _ in 0..entries {
            let k = rng.bounded((cap * 2) as u32);
            let t0 = SubMsTimer::tick();
            let _ = c.get(&k);
            s_get.record(t0.elapsed_ns());
        }

        let s_put = h.stage("put", entries).with_kind(SubMsStageKind::HotPath);
        let mut rng = SubMsLcg::new(seed.wrapping_add(2));
        for _ in 0..entries {
            let k = rng.bounded((cap * 4) as u32);
            let t0 = SubMsTimer::tick();
            c.put(k, k);
            s_put.record(t0.elapsed_ns());
        }

        h.add_meta("capacity", &cap.to_string());
    }
}