use crate::ctxhash::{CtxEq, CtxHash, CtxHashMap};
use smallvec::{SmallVec, smallvec};
struct Val<V> {
value: V,
level: u32,
generation: u32,
}
pub struct OccupiedEntry<'a, K: 'a, V: 'a> {
entry: crate::ctxhash::OccupiedEntry<'a, K, Val<V>>,
}
impl<'a, K, V> OccupiedEntry<'a, K, V> {
pub fn get(&self) -> &V {
&self.entry.get().value
}
}
pub struct VacantEntry<'a, K: 'a, V: 'a> {
entry: InsertLoc<'a, K, V>,
depth: u32,
generation: u32,
}
enum InsertLoc<'a, K: 'a, V: 'a> {
Vacant(crate::ctxhash::VacantEntry<'a, K, Val<V>>),
Occupied(crate::ctxhash::OccupiedEntry<'a, K, Val<V>>),
}
impl<'a, K, V> VacantEntry<'a, K, V> {
pub fn insert(self, value: V) {
let val = Val {
value,
level: self.depth,
generation: self.generation,
};
match self.entry {
InsertLoc::Vacant(v) => {
v.insert(val);
}
InsertLoc::Occupied(mut o) => {
*o.get_mut() = val;
}
}
}
}
pub enum Entry<'a, K: 'a, V: 'a> {
Occupied(OccupiedEntry<'a, K, V>),
Vacant(VacantEntry<'a, K, V>),
}
pub struct ScopedHashMap<K, V> {
map: CtxHashMap<K, Val<V>>,
generation_by_depth: SmallVec<[u32; 8]>,
generation: u32,
}
impl<K, V> ScopedHashMap<K, V>
where
K: Clone,
{
#[cfg(test)]
pub fn new() -> Self {
Self::with_capacity(16)
}
pub fn with_capacity(cap: usize) -> Self {
Self {
map: CtxHashMap::with_capacity(cap),
generation: 0,
generation_by_depth: smallvec![0],
}
}
pub fn entry<'a, C>(&'a mut self, ctx: &C, key: K) -> Entry<'a, K, V>
where
C: CtxEq<K, K> + CtxHash<K>,
{
self.entry_with_depth(ctx, key, self.depth())
}
pub fn entry_with_depth<'a, C>(&'a mut self, ctx: &C, key: K, depth: usize) -> Entry<'a, K, V>
where
C: CtxEq<K, K> + CtxHash<K>,
{
debug_assert!(depth <= self.generation_by_depth.len());
let generation = self.generation_by_depth[depth];
let depth = depth as u32;
match self.map.entry(key, ctx) {
crate::ctxhash::Entry::Occupied(entry) => {
let entry_generation = entry.get().generation;
let entry_depth = entry.get().level as usize;
if self.generation_by_depth.get(entry_depth).cloned() == Some(entry_generation) {
Entry::Occupied(OccupiedEntry { entry })
} else {
Entry::Vacant(VacantEntry {
entry: InsertLoc::Occupied(entry),
depth,
generation,
})
}
}
crate::ctxhash::Entry::Vacant(entry) => Entry::Vacant(VacantEntry {
entry: InsertLoc::Vacant(entry),
depth,
generation,
}),
}
}
pub fn get<'a, C>(&'a self, ctx: &C, key: &K) -> Option<&'a V>
where
C: CtxEq<K, K> + CtxHash<K>,
{
self.map
.get(key, ctx)
.filter(|entry| {
let level = entry.level as usize;
self.generation_by_depth.get(level).cloned() == Some(entry.generation)
})
.map(|entry| &entry.value)
}
pub fn insert_if_absent<C>(&mut self, ctx: &C, key: K, value: V)
where
C: CtxEq<K, K> + CtxHash<K>,
{
self.insert_if_absent_with_depth(ctx, key, value, self.depth());
}
pub fn insert_if_absent_with_depth<C>(&mut self, ctx: &C, key: K, value: V, depth: usize)
where
C: CtxEq<K, K> + CtxHash<K>,
{
match self.entry_with_depth(ctx, key, depth) {
Entry::Vacant(v) => {
v.insert(value);
}
Entry::Occupied(_) => {
}
}
}
pub fn insert_with_depth<C>(&mut self, ctx: &C, key: K, value: V, depth: usize)
where
C: CtxEq<K, K> + CtxHash<K>,
{
let val = Val {
value,
level: depth as u32,
generation: self.generation_by_depth[depth],
};
self.map.insert(key, val, ctx);
}
pub fn increment_depth(&mut self) {
self.generation_by_depth.push(self.generation);
}
pub fn decrement_depth(&mut self) {
self.generation += 1;
self.generation_by_depth.pop();
}
pub fn depth(&self) -> usize {
self.generation_by_depth
.len()
.checked_sub(1)
.expect("generation_by_depth cannot be empty")
}
}
#[cfg(test)]
mod tests {
use super::*;
use crate::ctxhash::NullCtx;
#[test]
fn basic() {
let mut map: ScopedHashMap<i32, i32> = ScopedHashMap::new();
match map.entry(&NullCtx, 0) {
Entry::Occupied(_entry) => panic!(),
Entry::Vacant(entry) => entry.insert(1),
}
match map.entry(&NullCtx, 2) {
Entry::Occupied(_entry) => panic!(),
Entry::Vacant(entry) => entry.insert(8),
}
match map.entry(&NullCtx, 2) {
Entry::Occupied(entry) => assert!(*entry.get() == 8),
Entry::Vacant(_entry) => panic!(),
}
map.increment_depth();
match map.entry(&NullCtx, 2) {
Entry::Occupied(entry) => assert!(*entry.get() == 8),
Entry::Vacant(_entry) => panic!(),
}
match map.entry(&NullCtx, 1) {
Entry::Occupied(_entry) => panic!(),
Entry::Vacant(entry) => entry.insert(3),
}
match map.entry(&NullCtx, 1) {
Entry::Occupied(entry) => assert!(*entry.get() == 3),
Entry::Vacant(_entry) => panic!(),
}
match map.entry(&NullCtx, 0) {
Entry::Occupied(entry) => assert!(*entry.get() == 1),
Entry::Vacant(_entry) => panic!(),
}
match map.entry(&NullCtx, 2) {
Entry::Occupied(entry) => assert!(*entry.get() == 8),
Entry::Vacant(_entry) => panic!(),
}
map.decrement_depth();
match map.entry(&NullCtx, 0) {
Entry::Occupied(entry) => assert!(*entry.get() == 1),
Entry::Vacant(_entry) => panic!(),
}
match map.entry(&NullCtx, 2) {
Entry::Occupied(entry) => assert!(*entry.get() == 8),
Entry::Vacant(_entry) => panic!(),
}
map.increment_depth();
match map.entry(&NullCtx, 2) {
Entry::Occupied(entry) => assert!(*entry.get() == 8),
Entry::Vacant(_entry) => panic!(),
}
match map.entry(&NullCtx, 1) {
Entry::Occupied(_entry) => panic!(),
Entry::Vacant(entry) => entry.insert(4),
}
match map.entry(&NullCtx, 1) {
Entry::Occupied(entry) => assert!(*entry.get() == 4),
Entry::Vacant(_entry) => panic!(),
}
match map.entry(&NullCtx, 2) {
Entry::Occupied(entry) => assert!(*entry.get() == 8),
Entry::Vacant(_entry) => panic!(),
}
map.decrement_depth();
map.increment_depth();
map.increment_depth();
map.increment_depth();
match map.entry(&NullCtx, 2) {
Entry::Occupied(entry) => assert!(*entry.get() == 8),
Entry::Vacant(_entry) => panic!(),
}
match map.entry(&NullCtx, 1) {
Entry::Occupied(_entry) => panic!(),
Entry::Vacant(entry) => entry.insert(5),
}
match map.entry(&NullCtx, 1) {
Entry::Occupied(entry) => assert!(*entry.get() == 5),
Entry::Vacant(_entry) => panic!(),
}
match map.entry(&NullCtx, 2) {
Entry::Occupied(entry) => assert!(*entry.get() == 8),
Entry::Vacant(_entry) => panic!(),
}
map.decrement_depth();
map.decrement_depth();
map.decrement_depth();
match map.entry(&NullCtx, 2) {
Entry::Occupied(entry) => assert!(*entry.get() == 8),
Entry::Vacant(_entry) => panic!(),
}
match map.entry(&NullCtx, 1) {
Entry::Occupied(_entry) => panic!(),
Entry::Vacant(entry) => entry.insert(3),
}
}
#[test]
fn insert_arbitrary_depth() {
let mut map: ScopedHashMap<i32, i32> = ScopedHashMap::new();
map.insert_if_absent(&NullCtx, 1, 2);
assert_eq!(map.get(&NullCtx, &1), Some(&2));
map.increment_depth();
assert_eq!(map.get(&NullCtx, &1), Some(&2));
map.insert_if_absent(&NullCtx, 3, 4);
assert_eq!(map.get(&NullCtx, &3), Some(&4));
map.decrement_depth();
assert_eq!(map.get(&NullCtx, &3), None);
map.increment_depth();
map.insert_if_absent_with_depth(&NullCtx, 3, 4, 0);
assert_eq!(map.get(&NullCtx, &3), Some(&4));
map.decrement_depth();
assert_eq!(map.get(&NullCtx, &3), Some(&4));
}
}