#![allow(unused_unsafe)]
use std;
use std::iter::FusedIterator;
use std::marker::PhantomData;
use std::mem::ManuallyDrop;
use std::ops::{Index, IndexMut};
use std::{fmt, ptr};
use super::{DefaultKey, Key, KeyData, Slottable};
#[derive(Clone, Copy, Debug)]
struct FreeListEntry {
next: u32,
prev: u32,
other_end: u32,
}
union SlotUnion<T: Slottable> {
value: ManuallyDrop<T>,
free: FreeListEntry,
}
struct Slot<T: Slottable> {
u: SlotUnion<T>,
version: u32, }
enum SlotContent<'a, T: 'a + Slottable> {
Occupied(&'a T),
Vacant(&'a FreeListEntry),
}
use self::SlotContent::{Occupied, Vacant};
impl<T: Slottable> Slot<T> {
#[inline(always)]
pub fn occupied(&self) -> bool {
self.version % 2 > 0
}
pub fn get(&self) -> SlotContent<T> {
unsafe {
if self.occupied() {
Occupied(&*self.u.value)
} else {
Vacant(&self.u.free)
}
}
}
}
impl<T: Slottable> Drop for Slot<T> {
fn drop(&mut self) {
if std::mem::needs_drop::<T>() && self.occupied() {
unsafe {
ManuallyDrop::drop(&mut self.u.value);
}
}
}
}
impl<T: Clone + Slottable> Clone for Slot<T> {
fn clone(&self) -> Self {
Self {
u: match self.get() {
Occupied(value) => SlotUnion {
value: ManuallyDrop::new(value.clone()),
},
Vacant(&free) => SlotUnion { free },
},
version: self.version,
}
}
}
impl<T: fmt::Debug + Slottable> fmt::Debug for Slot<T> {
fn fmt(&self, fmt: &mut fmt::Formatter) -> fmt::Result {
let mut builder = fmt.debug_struct("Slot");
builder.field("version", &self.version);
match self.get() {
Occupied(value) => builder.field("value", value).finish(),
Vacant(free) => builder.field("free", free).finish(),
}
}
}
#[derive(Debug, Clone)]
pub struct HopSlotMap<K: Key, V: Slottable> {
slots: Vec<Slot<V>>,
num_elems: u32,
_k: PhantomData<fn(K) -> K>,
}
impl<V: Slottable> HopSlotMap<DefaultKey, V> {
pub fn new() -> Self {
Self::with_capacity_and_key(0)
}
pub fn with_capacity(capacity: usize) -> Self {
Self::with_capacity_and_key(capacity)
}
}
impl<K: Key, V: Slottable> HopSlotMap<K, V> {
pub fn with_key() -> Self {
Self::with_capacity_and_key(0)
}
pub fn with_capacity_and_key(capacity: usize) -> Self {
let mut slots = Vec::with_capacity(capacity + 1);
slots.push(Slot {
u: SlotUnion {
free: FreeListEntry {
next: 0,
prev: 0,
other_end: 0,
},
},
version: 0,
});
Self {
slots,
num_elems: 0,
_k: PhantomData,
}
}
pub fn len(&self) -> usize {
self.num_elems as usize
}
pub fn is_empty(&self) -> bool {
self.num_elems == 0
}
pub fn capacity(&self) -> usize {
self.slots.capacity() - 1
}
pub fn reserve(&mut self, additional: usize) {
let needed = (self.len() + additional).saturating_sub(self.slots.len() - 1);
self.slots.reserve(needed);
}
pub fn contains_key(&self, key: K) -> bool {
let key = key.into();
self.slots
.get(key.idx as usize)
.map_or(false, |slot| slot.version == key.version.get())
}
pub fn insert(&mut self, value: V) -> K {
self.insert_with_key(|_| value)
}
unsafe fn freelist(&mut self, idx: u32) -> &mut FreeListEntry {
&mut self.slots.get_unchecked_mut(idx as usize).u.free
}
pub fn insert_with_key<F>(&mut self, f: F) -> K
where
F: FnOnce(K) -> V,
{
let new_num_elems = self.num_elems + 1;
if new_num_elems == std::u32::MAX {
panic!("HopSlotMap number of elements overflow");
}
unsafe {
let head = self.freelist(0).next;
let front = head;
let back = self.freelist(front).other_end;
let slot_idx = back as usize;
if slot_idx == 0 {
let key = KeyData::new(self.slots.len() as u32, 1);
self.slots.push(Slot {
u: SlotUnion {
value: ManuallyDrop::new(f(key.into())),
},
version: 1,
});
self.num_elems = new_num_elems;
return key.into();
}
let (key, value, occupied_version);
{
let slot = &mut self.slots[slot_idx];
occupied_version = slot.version | 1;
key = KeyData::new(slot_idx as u32, occupied_version);
value = f(key.into());
}
if front == back {
let new_head = self.freelist(front).next;
self.freelist(0).next = new_head;
self.freelist(new_head).prev = 0;
} else {
let new_back = back - 1;
self.freelist(new_back).other_end = front;
self.freelist(front).other_end = new_back;
}
let slot = &mut self.slots[slot_idx];
slot.version = occupied_version;
slot.u.value = ManuallyDrop::new(value);
self.num_elems = new_num_elems;
key.into()
}
}
#[inline(always)]
unsafe fn remove_from_slot(&mut self, idx: usize) -> V {
let value = {
let slot = self.slots.get_unchecked_mut(idx);
slot.version = slot.version.wrapping_add(1);
ptr::read(&*slot.u.value)
};
let left_vacant = !self.slots.get_unchecked(idx - 1).occupied();
let right_vacant = self.slots.get(idx + 1).map_or(false, |s| !s.occupied());
let i = idx as u32;
match (left_vacant, right_vacant) {
(false, false) => {
let old_head = self.freelist(0).next;
self.freelist(0).next = i;
self.freelist(old_head).prev = i;
*self.freelist(i) = FreeListEntry {
other_end: i,
next: old_head,
prev: 0,
};
}
(false, true) => {
let front_data = *self.freelist(i + 1);
*self.freelist(i) = front_data;
self.freelist(front_data.other_end).other_end = i;
self.freelist(front_data.prev).next = i;
self.freelist(front_data.next).prev = i;
}
(true, false) => {
let front = self.freelist(i - 1).other_end;
self.freelist(i).other_end = front;
self.freelist(front).other_end = i;
}
(true, true) => {
let right = *self.freelist(i + 1);
self.freelist(right.prev).next = right.next;
self.freelist(right.next).prev = right.prev;
let front = self.freelist(i - 1).other_end;
let back = right.other_end;
self.freelist(front).other_end = back;
self.freelist(back).other_end = front;
}
}
self.num_elems -= 1;
value
}
pub fn remove(&mut self, key: K) -> Option<V> {
let key = key.into();
if self.contains_key(key.into()) {
Some(unsafe { self.remove_from_slot(key.idx as usize) })
} else {
None
}
}
pub fn retain<F>(&mut self, mut f: F)
where
F: FnMut(K, &mut V) -> bool,
{
let mut elems_left_to_scan = self.len();
let mut cur = unsafe { self.slots.get_unchecked(0).u.free.other_end as usize + 1 };
while elems_left_to_scan > 0 {
let idx = cur;
let slot = unsafe { self.slots.get_unchecked_mut(cur) };
let version = slot.version;
let key = KeyData::new(cur as u32, version).into();
let should_remove = !f(key, unsafe { &mut *slot.u.value });
cur = match self.slots.get(cur + 1).map(|s| s.get()) {
Some(Occupied(_)) => cur + 1,
Some(Vacant(free)) => free.other_end as usize + 1,
None => 0,
};
if should_remove {
unsafe { self.remove_from_slot(idx) };
}
elems_left_to_scan -= 1;
}
}
pub fn clear(&mut self) {
self.drain();
}
pub fn drain(&mut self) -> Drain<K, V> {
Drain {
cur: unsafe { self.slots.get_unchecked(0).u.free.other_end as usize + 1 },
sm: self,
}
}
pub fn get(&self, key: K) -> Option<&V> {
let key = key.into();
self.slots
.get(key.idx as usize)
.filter(|slot| slot.version == key.version.get())
.map(|slot| unsafe { &*slot.u.value })
}
pub unsafe fn get_unchecked(&self, key: K) -> &V {
let key = key.into();
&self.slots.get_unchecked(key.idx as usize).u.value
}
pub fn get_mut(&mut self, key: K) -> Option<&mut V> {
let key = key.into();
self.slots
.get_mut(key.idx as usize)
.filter(|slot| slot.version == key.version.get())
.map(|slot| unsafe { &mut *slot.u.value })
}
pub unsafe fn get_unchecked_mut(&mut self, key: K) -> &mut V {
let key = key.into();
&mut self.slots.get_unchecked_mut(key.idx as usize).u.value
}
pub fn iter(&self) -> Iter<K, V> {
Iter {
cur: unsafe { self.slots.get_unchecked(0).u.free.other_end as usize + 1 },
num_left: self.len(),
slots: &self.slots[..],
_k: PhantomData,
}
}
pub fn iter_mut(&mut self) -> IterMut<K, V> {
IterMut {
cur: 0,
num_left: self.len(),
slots: &mut self.slots[..],
_k: PhantomData,
}
}
pub fn keys(&self) -> Keys<K, V> {
Keys { inner: self.iter() }
}
pub fn values(&self) -> Values<K, V> {
Values { inner: self.iter() }
}
pub fn values_mut(&mut self) -> ValuesMut<K, V> {
ValuesMut {
inner: self.iter_mut(),
}
}
}
impl<K: Key, V: Slottable> Default for HopSlotMap<K, V> {
fn default() -> Self {
Self::with_key()
}
}
impl<K: Key, V: Slottable> Index<K> for HopSlotMap<K, V> {
type Output = V;
fn index(&self, key: K) -> &V {
match self.get(key) {
Some(r) => r,
None => panic!("invalid HopSlotMap key used"),
}
}
}
impl<K: Key, V: Slottable> IndexMut<K> for HopSlotMap<K, V> {
fn index_mut(&mut self, key: K) -> &mut V {
match self.get_mut(key) {
Some(r) => r,
None => panic!("invalid HopSlotMap key used"),
}
}
}
#[derive(Debug)]
pub struct Drain<'a, K: Key + 'a, V: Slottable + 'a> {
cur: usize,
sm: &'a mut HopSlotMap<K, V>,
}
#[derive(Debug)]
pub struct IntoIter<K: Key, V: Slottable> {
cur: usize,
num_left: usize,
slots: Vec<Slot<V>>,
_k: PhantomData<fn(K) -> K>,
}
#[derive(Debug)]
pub struct Iter<'a, K: Key + 'a, V: Slottable + 'a> {
cur: usize,
num_left: usize,
slots: &'a [Slot<V>],
_k: PhantomData<fn(K) -> K>,
}
#[derive(Debug)]
pub struct IterMut<'a, K: Key + 'a, V: Slottable + 'a> {
cur: usize,
num_left: usize,
slots: &'a mut [Slot<V>],
_k: PhantomData<fn(K) -> K>,
}
#[derive(Debug)]
pub struct Keys<'a, K: Key + 'a, V: Slottable + 'a> {
inner: Iter<'a, K, V>,
}
#[derive(Debug)]
pub struct Values<'a, K: Key + 'a, V: Slottable + 'a> {
inner: Iter<'a, K, V>,
}
#[derive(Debug)]
pub struct ValuesMut<'a, K: Key + 'a, V: Slottable + 'a> {
inner: IterMut<'a, K, V>,
}
impl<'a, K: Key, V: Slottable> Iterator for Drain<'a, K, V> {
type Item = (K, V);
fn next(&mut self) -> Option<(K, V)> {
if self.sm.len() == 0 {
return None;
}
let idx = self.cur;
self.cur = match self.sm.slots.get(idx + 1).map(|s| s.get()) {
Some(Occupied(_)) => idx + 1,
Some(Vacant(free)) => free.other_end as usize + 1,
None => 0,
};
let key = KeyData::new(idx as u32, unsafe {
self.sm.slots.get_unchecked(idx).version
});
Some((key.into(), unsafe { self.sm.remove_from_slot(idx) }))
}
fn size_hint(&self) -> (usize, Option<usize>) {
(self.sm.len(), Some(self.sm.len()))
}
}
impl<'a, K: Key, V: Slottable> Drop for Drain<'a, K, V> {
fn drop(&mut self) {
self.for_each(|_drop| {});
}
}
impl<K: Key, V: Slottable> Iterator for IntoIter<K, V> {
type Item = (K, V);
fn next(&mut self) -> Option<(K, V)> {
if self.cur >= self.slots.len() {
return None;
}
let idx = match self.slots[self.cur].get() {
Occupied(_) => self.cur,
Vacant(free) => {
let idx = free.other_end as usize + 1;
if idx >= self.slots.len() {
return None;
}
idx
}
};
self.cur = idx + 1;
self.num_left -= 1;
let slot = &mut self.slots[idx];
let key = KeyData::new(idx as u32, slot.version);
slot.version = 0; Some((key.into(), unsafe { ptr::read(&*slot.u.value) }))
}
fn size_hint(&self) -> (usize, Option<usize>) {
(self.num_left, Some(self.num_left))
}
}
impl<'a, K: Key, V: Slottable> Iterator for Iter<'a, K, V> {
type Item = (K, &'a V);
fn next(&mut self) -> Option<(K, &'a V)> {
if self.num_left == 0 {
return None;
}
self.num_left -= 1;
let idx = match unsafe { self.slots.get_unchecked(self.cur).get() } {
Occupied(_) => self.cur,
Vacant(free) => free.other_end as usize + 1,
};
self.cur = idx + 1;
let slot = unsafe { self.slots.get_unchecked(idx) };
let key = KeyData::new(idx as u32, slot.version).into();
Some((key, unsafe { &*slot.u.value }))
}
fn size_hint(&self) -> (usize, Option<usize>) {
(self.num_left, Some(self.num_left))
}
}
impl<'a, K: Key, V: Slottable> Iterator for IterMut<'a, K, V> {
type Item = (K, &'a mut V);
fn next(&mut self) -> Option<(K, &'a mut V)> {
if self.cur >= self.slots.len() {
return None;
}
let idx = match self.slots[self.cur].get() {
Occupied(_) => self.cur,
Vacant(free) => {
let idx = free.other_end as usize + 1;
if idx >= self.slots.len() {
return None;
}
idx
}
};
self.cur = idx + 1;
self.num_left -= 1;
let slot = &mut self.slots[idx];
let version = slot.version;
let value_ref = unsafe { &mut *(&mut *slot.u.value as *mut V) };
Some((KeyData::new(idx as u32, version).into(), value_ref))
}
fn size_hint(&self) -> (usize, Option<usize>) {
(self.num_left, Some(self.num_left))
}
}
impl<'a, K: Key, V: Slottable> Iterator for Keys<'a, K, V> {
type Item = K;
fn next(&mut self) -> Option<K> {
self.inner.next().map(|(key, _)| key)
}
fn size_hint(&self) -> (usize, Option<usize>) {
self.inner.size_hint()
}
}
impl<'a, K: Key, V: Slottable> Iterator for Values<'a, K, V> {
type Item = &'a V;
fn next(&mut self) -> Option<&'a V> {
self.inner.next().map(|(_, value)| value)
}
fn size_hint(&self) -> (usize, Option<usize>) {
self.inner.size_hint()
}
}
impl<'a, K: Key, V: Slottable> Iterator for ValuesMut<'a, K, V> {
type Item = &'a mut V;
fn next(&mut self) -> Option<&'a mut V> {
self.inner.next().map(|(_, value)| value)
}
fn size_hint(&self) -> (usize, Option<usize>) {
self.inner.size_hint()
}
}
impl<'a, K: Key, V: Slottable> IntoIterator for &'a HopSlotMap<K, V> {
type Item = (K, &'a V);
type IntoIter = Iter<'a, K, V>;
fn into_iter(self) -> Self::IntoIter {
self.iter()
}
}
impl<'a, K: Key, V: Slottable> IntoIterator for &'a mut HopSlotMap<K, V> {
type Item = (K, &'a mut V);
type IntoIter = IterMut<'a, K, V>;
fn into_iter(self) -> Self::IntoIter {
self.iter_mut()
}
}
impl<K: Key, V: Slottable> IntoIterator for HopSlotMap<K, V> {
type Item = (K, V);
type IntoIter = IntoIter<K, V>;
fn into_iter(self) -> Self::IntoIter {
IntoIter {
cur: 0,
num_left: self.len(),
slots: self.slots,
_k: PhantomData,
}
}
}
impl<'a, K: Key, V: Slottable> FusedIterator for Iter<'a, K, V> {}
impl<'a, K: Key, V: Slottable> FusedIterator for IterMut<'a, K, V> {}
impl<'a, K: Key, V: Slottable> FusedIterator for Keys<'a, K, V> {}
impl<'a, K: Key, V: Slottable> FusedIterator for Values<'a, K, V> {}
impl<'a, K: Key, V: Slottable> FusedIterator for ValuesMut<'a, K, V> {}
impl<'a, K: Key, V: Slottable> FusedIterator for Drain<'a, K, V> {}
impl<K: Key, V: Slottable> FusedIterator for IntoIter<K, V> {}
impl<'a, K: Key, V: Slottable> ExactSizeIterator for Iter<'a, K, V> {}
impl<'a, K: Key, V: Slottable> ExactSizeIterator for IterMut<'a, K, V> {}
impl<'a, K: Key, V: Slottable> ExactSizeIterator for Keys<'a, K, V> {}
impl<'a, K: Key, V: Slottable> ExactSizeIterator for Values<'a, K, V> {}
impl<'a, K: Key, V: Slottable> ExactSizeIterator for ValuesMut<'a, K, V> {}
impl<'a, K: Key, V: Slottable> ExactSizeIterator for Drain<'a, K, V> {}
impl<K: Key, V: Slottable> ExactSizeIterator for IntoIter<K, V> {}
#[cfg(feature = "serde")]
mod serialize {
use super::*;
use serde::{de, Deserialize, Deserializer, Serialize, Serializer};
#[derive(Serialize, Deserialize)]
struct SerdeSlot<T> {
value: Option<T>,
version: u32,
}
impl<T: Serialize + Slottable> Serialize for Slot<T> {
fn serialize<S>(&self, serializer: S) -> Result<S::Ok, S::Error>
where
S: Serializer,
{
let serde_slot = SerdeSlot {
version: self.version,
value: match self.get() {
Occupied(value) => Some(value),
Vacant(_) => None,
},
};
serde_slot.serialize(serializer)
}
}
impl<'de, T: Slottable> Deserialize<'de> for Slot<T>
where
T: Deserialize<'de>,
{
fn deserialize<D>(deserializer: D) -> Result<Self, D::Error>
where
D: Deserializer<'de>,
{
let serde_slot: SerdeSlot<T> = Deserialize::deserialize(deserializer)?;
let occupied = serde_slot.version % 2 > 0;
if occupied ^ serde_slot.value.is_some() {
return Err(de::Error::custom(&"inconsistent occupation in Slot"));
}
Ok(Self {
u: match serde_slot.value {
Some(value) => SlotUnion {
value: ManuallyDrop::new(value),
},
None => SlotUnion {
free: FreeListEntry {
next: 0,
prev: 0,
other_end: 0,
},
},
},
version: serde_slot.version,
})
}
}
impl<K: Key, V: Serialize + Slottable> Serialize for HopSlotMap<K, V> {
fn serialize<S>(&self, serializer: S) -> Result<S::Ok, S::Error>
where
S: Serializer,
{
self.slots.serialize(serializer)
}
}
impl<'de, K: Key, V: Deserialize<'de> + Slottable> Deserialize<'de> for HopSlotMap<K, V> {
fn deserialize<D>(deserializer: D) -> Result<Self, D::Error>
where
D: Deserializer<'de>,
{
let mut slots: Vec<Slot<V>> = Deserialize::deserialize(deserializer)?;
if slots.len() >= (1 << 32) - 1 {
return Err(de::Error::custom(&"too many slots"));
}
if slots.get(0).map_or(true, |slot| slot.version % 2 > 0) {
return Err(de::Error::custom(&"first slot not empty"));
}
slots[0].u.free = FreeListEntry {
next: 0,
prev: 0,
other_end: 0,
};
let mut num_elems = 0;
let mut prev = 0;
let mut i = 0;
while i < slots.len() {
let front = i;
while i < slots.len() && !slots[i].occupied() {
i += 1;
}
let back = i - 1;
unsafe {
slots[back].u.free.other_end = front as u32;
slots[prev].u.free.next = front as u32;
slots[front].u.free = FreeListEntry {
next: 0,
prev: prev as u32,
other_end: back as u32,
};
}
prev = front;
while i < slots.len() && slots[i].occupied() {
num_elems += 1;
i += 1;
}
}
Ok(Self {
num_elems,
slots,
_k: PhantomData,
})
}
}
}
#[cfg(test)]
mod tests {
use super::*;
use std::collections::HashMap;
#[cfg(feature = "serde")]
use serde_json;
#[cfg(feature = "unstable")]
#[test]
fn check_drops() {
let drops = std::cell::RefCell::new(0usize);
#[derive(Clone)]
struct CountDrop<'a>(&'a std::cell::RefCell<usize>);
impl<'a> Drop for CountDrop<'a> {
fn drop(&mut self) {
*self.0.borrow_mut() += 1;
}
}
{
let mut clone = {
let mut sm = HopSlotMap::new();
let mut sm_keys = Vec::new();
for _ in 0..1000 {
sm_keys.push(sm.insert(CountDrop(&drops)));
}
for i in (0..1000).filter(|i| i % 2 == 0) {
sm.remove(sm_keys[i]);
}
assert_eq!(*drops.borrow(), 500);
sm.clone()
};
assert_eq!(*drops.borrow(), 1000);
for _ in 0..250 {
clone.insert(CountDrop(&drops));
}
}
assert_eq!(*drops.borrow(), 1750);
}
quickcheck! {
fn qc_slotmap_equiv_hashmap(operations: Vec<(u8, u32)>) -> bool {
let mut hm = HashMap::new();
let mut hm_keys = Vec::new();
let mut unique_key = 0u32;
let mut sm = HopSlotMap::new();
let mut sm_keys = Vec::new();
#[cfg(not(feature = "serde"))]
let num_ops = 3;
#[cfg(feature = "serde")]
let num_ops = 4;
for (op, val) in operations {
match op % num_ops {
0 => {
hm.insert(unique_key, val);
hm_keys.push(unique_key);
unique_key += 1;
sm_keys.push(sm.insert(val));
}
1 => {
if hm_keys.len() == 0 { continue; }
let idx = val as usize % hm_keys.len();
if hm.remove(&hm_keys[idx]) != sm.remove(sm_keys[idx]) {
return false;
}
}
2 => {
if hm_keys.len() == 0 { continue; }
let idx = val as usize % hm_keys.len();
let (hm_key, sm_key) = (&hm_keys[idx], sm_keys[idx]);
if hm.contains_key(hm_key) != sm.contains_key(sm_key) ||
hm.get(hm_key) != sm.get(sm_key) {
return false;
}
}
#[cfg(feature = "serde")]
3 => {
let ser = serde_json::to_string(&sm).unwrap();
sm = serde_json::from_str(&ser).unwrap();
}
_ => unreachable!(),
}
}
let mut smv: Vec<_> = sm.values().collect();
let mut hmv: Vec<_> = hm.values().collect();
smv.sort();
hmv.sort();
smv == hmv
}
}
#[cfg(feature = "serde")]
#[test]
fn slotmap_serde() {
let mut sm = HopSlotMap::new();
let first = sm.insert_with_key(|k| (k, 23i32));
let second = sm.insert((first, 42));
let empties = vec![sm.insert((first, 0)), sm.insert((first, 0))];
empties.iter().for_each(|k| {
sm.remove(*k);
});
let third = sm.insert((second, 0));
sm[first].0 = third;
let ser = serde_json::to_string(&sm).unwrap();
let de: HopSlotMap<DefaultKey, (DefaultKey, i32)> = serde_json::from_str(&ser).unwrap();
assert_eq!(de.len(), sm.len());
let mut smkv: Vec<_> = sm.iter().collect();
let mut dekv: Vec<_> = de.iter().collect();
smkv.sort();
dekv.sort();
assert_eq!(smkv, dekv);
}
#[cfg(feature = "serde")]
#[test]
fn slotmap_serde_freelist() {
let mut sm = HopSlotMap::new();
let k = sm.insert(5i32);
sm.remove(k);
let ser = serde_json::to_string(&sm).unwrap();
let mut de: HopSlotMap<DefaultKey, i32> = serde_json::from_str(&ser).unwrap();
de.insert(0);
de.insert(1);
de.insert(2);
assert_eq!(de.len(), 3);
}
}