use super::*;
use crate::mem::tests::check_links;
use mem::{FileMapped, Global};
#[test]
fn deletion_of_reset_link_does_not_update_again() {
let mut store = Store::<usize, _>::new(Global::new()).unwrap();
let index = store.create_point().unwrap();
store.update(index, 0, 0).unwrap();
let updates = store.update_calls;
assert_eq!(store.delete(index).unwrap(), index);
assert_eq!(store.update_calls, updates, "release must not reset again");
}
fn check_growth(memory: impl RawMem<Item = LinkPart<usize>>) {
let mut store = Store::<usize, _>::new(memory).unwrap();
assert_eq!(store.mem_ptr.len(), store.reserve_step);
assert_eq!(store.mem_ptr.len(), store.mem.allocated().len());
assert_eq!(store.get_header().reserved, store.mem_ptr.len() - 1);
let memory = NonNull::from(crate::mem::resize_mem(&mut store.mem, 16).unwrap());
store.update_mem(memory);
store.reserve_step = 16;
store.mut_header().reserved = 15;
for index in 1..=50 {
assert_eq!(store.create_point().unwrap(), index);
assert_eq!(store.mem_ptr.len(), store.mem.allocated().len());
check_links(&store, index);
}
assert_eq!(store.mem_ptr.len(), 64);
}
#[test]
fn global_initial_capacity_and_repeated_growth_preserve_links() {
check_growth(Global::new());
}
#[test]
fn file_mapped_initial_capacity_and_repeated_growth_preserve_links() {
let directory = tempfile::tempdir().unwrap();
let path = directory.path().join("links");
check_growth(FileMapped::from_path(&path).unwrap());
let store = Store::<usize, _>::new(FileMapped::from_path(&path).unwrap()).unwrap();
check_links(&store, 50);
}
#[test]
fn byte_store_can_allocate_its_full_address_range() {
let mut store = Store::<u8, _>::new(Global::new()).unwrap();
let limit = *store.constants().internal_range.end();
for index in 1..=limit {
assert_eq!(store.create_point().unwrap(), index);
}
assert!(matches!(store.create(), Err(LinksError::LimitReached(value)) if value == limit));
}
#[test]
fn minimal_release_and_resolver_do_only_required_updates() {
use crate::{
decorators::{CheckedRelease, DecoratorsExt},
mem::Release,
};
let mut store = Store::<usize, _>::new(Global::new()).unwrap();
let index = store.create_point().unwrap();
let updates = store.update_calls;
assert!(matches!(
store.release(index),
Err(LinksError::NonNullContents(_))
));
assert_eq!(store.update_calls, updates);
store.update(index, 0, 0).unwrap();
let updates = store.update_calls;
store.release(index).unwrap();
assert_eq!(store.update_calls, updates);
let index = store.create().unwrap();
unsafe { store.release_unchecked(index, &mut |_, _| Flow::Continue) };
assert_eq!(store.update_calls, updates);
let index = store.create_point().unwrap();
let updates = store.update_calls;
CheckedRelease::new(&mut store)
.with_non_null_contents_deletion_resolution()
.delete(index)
.unwrap();
assert_eq!(store.update_calls, updates + 1);
let index = store.create().unwrap();
let updates = store.update_calls;
CheckedRelease::new(&mut store)
.with_non_null_contents_deletion_resolution()
.delete(index)
.unwrap();
assert_eq!(store.update_calls, updates);
}