/* This Source Code Form is subject to the terms of the Mozilla Public * License, v. 2.0. If a copy of the MPL was not distributed with this * file, You can obtain one at http://mozilla.org/MPL/2.0/. */ use rand; use rand::Rng; use std::collections::HashMap; use std::collections::hash_map::Entry::{Occupied, Vacant}; use std::default::Default; use std::hash::{BuildHasherDefault, Hash, Hasher, SipHasher}; use std::slice::Iter; #[derive(Debug)] pub struct HashCache where K: PartialEq + Eq + Hash, V: Clone, { entries: HashMap>, } impl HashCache where K: PartialEq + Eq + Hash, V: Clone, { pub fn new() -> HashCache { HashCache { entries: HashMap::with_hasher(Default::default()), } } pub fn insert(&mut self, key: K, value: V) { self.entries.insert(key, value); } pub fn find(&self, key: &K) -> Option { match self.entries.get(key) { Some(v) => Some(v.clone()), None => None, } } pub fn find_or_create(&mut self, key: K, mut blk: F) -> V where F: FnMut() -> V { match self.entries.entry(key) { Occupied(occupied) => { (*occupied.get()).clone() } Vacant(vacant) => { (*vacant.insert(blk())).clone() } } } pub fn evict_all(&mut self) { self.entries.clear(); } } pub struct LRUCache { entries: Vec<(K, V)>, cache_size: usize, } impl LRUCache { pub fn new(size: usize) -> LRUCache { LRUCache { entries: vec!(), cache_size: size, } } #[inline] pub fn touch(&mut self, pos: usize) -> &V { let last_index = self.entries.len() - 1; if pos != last_index { let entry = self.entries.remove(pos); self.entries.push(entry); } &self.entries[last_index].1 } pub fn iter(&self) -> Iter<(K, V)> { self.entries.iter() } pub fn insert(&mut self, key: K, val: V) { if self.entries.len() == self.cache_size { self.entries.remove(0); } self.entries.push((key, val)); } pub fn find(&mut self, key: &K) -> Option { match self.entries.iter().position(|&(ref k, _)| key == k) { Some(pos) => Some(self.touch(pos).clone()), None => None, } } pub fn find_or_create(&mut self, key: K, mut blk: F) -> V where F: FnMut() -> V { match self.entries.iter().position(|&(ref k, _)| *k == key) { Some(pos) => self.touch(pos).clone(), None => { let val = blk(); self.insert(key, val.clone()); val } } } pub fn evict_all(&mut self) { self.entries.clear(); } } pub struct SimpleHashCache { entries: Vec>, k0: u64, k1: u64, } impl SimpleHashCache { pub fn new(cache_size: usize) -> SimpleHashCache { let mut r = rand::thread_rng(); SimpleHashCache { entries: vec![None; cache_size], k0: r.gen(), k1: r.gen(), } } #[inline] fn to_bucket(&self, h: usize) -> usize { h % self.entries.len() } #[inline] fn bucket_for_key(&self, key: &Q) -> usize { let mut hasher = SipHasher::new_with_keys(self.k0, self.k1); key.hash(&mut hasher); self.to_bucket(hasher.finish() as usize) } pub fn insert(&mut self, key: K, value: V) { let bucket_index = self.bucket_for_key(&key); self.entries[bucket_index] = Some((key, value)); } pub fn find(&self, key: &Q) -> Option where Q: PartialEq + Hash + Eq { let bucket_index = self.bucket_for_key(key); match self.entries[bucket_index] { Some((ref existing_key, ref value)) if key == existing_key => Some((*value).clone()), _ => None, } } pub fn find_or_create(&mut self, key: K, mut blk: F) -> V where F: FnMut() -> V { if let Some(value) = self.find(&key) { return value; } let value = blk(); self.insert(key, value.clone()); value } pub fn evict_all(&mut self) { for slot in &mut self.entries { *slot = None } } }