{"header":{"message":"Tests","description":null,"timestamp":"2021-02-01T09:33:14.539619344Z","authors":[{"full_name":"Pierre-Étienne Meunier","name":"pmeunier"}]},"hash":"UAQX27N4PI4LHEW6LSHJETIE5MV7JTEMPLTJFYUBMYVPC43H7VOAC","authors":[],"deps":{"hashes":[["UAQX27N4PI4LHEW6LSHJETIE5MV7JTEMPLTJFYUBMYVPC43H7VOAC","Tests"],["AA",null],["OP6SVMOD2GTQ7VNJ4E5KYFG4MIYA7HBMXJTADALMZH4PY7OQRMZQC","Resetting history"]],"deps":["OP6SVMOD2GTQ7VNJ4E5KYFG4MIYA7HBMXJTADALMZH4PY7OQRMZQC"],"known":[]},"hunks":[{"FileAdd":{"meta":{"basename":"tests.rs","metadata":420},"context":[{"change":2,"pos":71008}],"contents":[{"Add":"use log::*;"},{"Add":"use std::collections::btree_map::Entry;"},{"Add":"use std::collections::BTreeMap;"},{"Add":""},{"Add":"use sanakirja_core::btree;"},{"Add":"use sanakirja_core::btree::*;"},{"Add":"use sanakirja_core::*;"},{"Add":""},{"Add":"use crate::environment::*;"},{"Add":"use crate::*;"},{"Add":""},{"Add":"type B = btree::page::Page>;"},{"Add":""},{"Add":"#[derive(Eq, PartialEq, PartialOrd, Ord)]"},{"Add":"struct A([u64; 100], std::marker::PhantomData);"},{"Add":""},{"Add":"impl std::fmt::Debug for A {"},{"Add":" fn fmt(&self, fmt: &mut std::fmt::Formatter) -> std::fmt::Result {"},{"Add":" write!(fmt, \"A(…)\")?;"},{"Add":" Ok(())"},{"Add":" }"},{"Add":"}"},{"Add":""},{"Add":"impl Representable for A {"},{"Add":" type PageOffsets = core::iter::Empty;"},{"Add":" fn page_offsets(&self) -> Self::PageOffsets {"},{"Add":" core::iter::empty()"},{"Add":" }"},{"Add":" const ALIGN: usize = core::mem::align_of::();"},{"Add":" const SIZE: Option = Some(core::mem::size_of::());"},{"Add":" type Ord = [u64; 100];"},{"Add":" fn ord(&self, _: &T) -> &Self::Ord {"},{"Add":" &self.0"},{"Add":" }"},{"Add":" fn size(&self) -> usize {"},{"Add":" core::mem::size_of::()"},{"Add":" }"},{"Add":"}"},{"Add":""},{"Add":"type T<'a> = MutTxn<&'a Env, ()>;"},{"Add":""},{"Add":"#[test]"},{"Add":"pub fn main() {"},{"Add":" env_logger::try_init().unwrap_or(());"},{"Add":" let env = Env::new_anon(409600000).unwrap();"},{"Add":" let mut txn = Env::mut_txn_begin(&env).unwrap();"},{"Add":" let mut db = create_db::, ()>, u64, A, B>(&mut txn).unwrap();"},{"Add":" let n = 100_000u64;"},{"Add":" let m = 1000;"},{"Add":" let now = std::time::SystemTime::now();"},{"Add":" let mut values = Vec::with_capacity(n as usize);"},{"Add":" let i0 = 500;"},{"Add":" for i in 0..n {"},{"Add":" // debug!(\"put {:?} {:?} {:?}\", i, (i*i)%m, i*i*i);"},{"Add":" if i != i0 && (i * i) % m == (i0 * i0) % m {"},{"Add":" continue;"},{"Add":" }"},{"Add":" let a = A([i * i * i; 100], std::marker::PhantomData);"},{"Add":" if put(&mut txn, &mut db, &((i * i) % m), &a).unwrap() {"},{"Add":" values.push((i * i) % m);"},{"Add":" } else {"},{"Add":" // debug!(\"not inserted\");"},{"Add":" }"},{"Add":" }"},{"Add":" debug!(\"{:?}\", now.elapsed());"},{"Add":" debug::debug(&txn, &db, \"debug_final\", true);"},{"Add":" values.sort();"},{"Add":""},{"Add":" let mut curs = btree::cursor::Cursor::new(&db);"},{"Add":" let mut nn = 0;"},{"Add":" while let Some((k, _v)) = curs.next(&mut txn).unwrap() {"},{"Add":" // debug!(\"{:?} {:?} {:?}\", k, values[nn], (v.0)[0]);"},{"Add":" assert_eq!(*k, values[nn]);"},{"Add":" nn += 1;"},{"Add":" }"},{"Add":" assert_eq!(nn, values.len());"},{"Add":""},{"Add":" let db2 = fork_db(&mut txn, &db).unwrap();"},{"Add":" let a = A([0; 100], std::marker::PhantomData);"},{"Add":" put(&mut txn, &mut db, &(m/2), &a).unwrap();"},{"Add":" let mut curs = btree::cursor::Cursor::new(&db);"},{"Add":" let (k, v) = curs"},{"Add":" .set(&txn, Some((&((i0 * i0) % m), None)))"},{"Add":" .unwrap()"},{"Add":" .unwrap();"},{"Add":" assert_eq!((i0 * i0) % m, *k);"},{"Add":" assert_eq!(i0 * i0 * i0, (v.0)[0]);"},{"Add":""},{"Add":" let mut curs = btree::cursor::Cursor::new(&db);"},{"Add":" let a = A([i0 * i0 * i0; 100], std::marker::PhantomData);"},{"Add":" let (k, v) = curs"},{"Add":" .set(&txn, Some((&((i0 * i0) % m), Some(&a))))"},{"Add":" .unwrap()"},{"Add":" .unwrap();"},{"Add":" assert_eq!((i0 * i0) % m, *k);"},{"Add":" assert_eq!(i0 * i0 * i0, (v.0)[0]);"},{"Add":""},{"Add":" let mut curs = btree::cursor::Cursor::new(&db);"},{"Add":" let (k, _) = curs.set_last(&txn).unwrap().unwrap();"},{"Add":" assert_eq!(k, values.last().unwrap());"},{"Add":" /*"},{"Add":" println!(\"moi: {:?}\", now.elapsed());"},{"Add":" let d = 10;"},{"Add":" for i in 0..d {"},{"Add":" debug!(\"deleting {:?}\", (i*i)%1_000_000);"},{"Add":" debug::debug(&txn, &db, &format!(\"debug{}\", i), true);"},{"Add":" del(&mut txn, &mut db, &((i * i) % 1_000_000), None).unwrap();"},{"Add":" }"},{"Add":" debug::debug(&txn, &db, \"debug_final\", true);"},{"Add":" txn.commit().unwrap();"},{"Add":" */"},{"Add":" /*"},{"Add":" let mut btree = std::collections::BTreeMap::new();"},{"Add":" let now = std::time::SystemTime::now();"},{"Add":" for i in 0..n {"},{"Add":" btree.insert(i * i, i * i * i);"},{"Add":" }"},{"Add":" println!(\"std: {:?}\", now.elapsed());"},{"Add":" */"},{"Add":""},{"Add":" /*"},{"Add":" std::mem::forget(txn);"},{"Add":" {"},{"Add":" let env = EnvBuilder::new()"},{"Add":" .map_size(1 << 27)"},{"Add":" .open(\"test-lmdb\", 0o777)"},{"Add":" .unwrap();"},{"Add":""},{"Add":" let db_handle = env.get_default_db(DbFlags::empty()).unwrap();"},{"Add":" let txn = env.new_transaction().unwrap();"},{"Add":" {"},{"Add":" let db = txn.bind(&db_handle); // get a database bound to this transaction"},{"Add":" let now = std::time::SystemTime::now();"},{"Add":" for i in 0..n {"},{"Add":" db.set(&(i * i), &(i * i * i)).unwrap();"},{"Add":" }"},{"Add":" println!(\"lmdb: {:?}\", now.elapsed());"},{"Add":" }"},{"Add":" }"},{"Add":" */"},{"Add":"}"},{"Add":""},{"Add":"#[test]"},{"Add":"pub fn u64_unit() {"},{"Add":" type B = btree::page::Page;"},{"Add":" env_logger::try_init().unwrap_or(());"},{"Add":" let env = Env::new_anon(409600000).unwrap();"},{"Add":" let mut txn = Env::mut_txn_begin(&env).unwrap();"},{"Add":" let mut db: Db<_, u64, (), B> = create_db(&mut txn).unwrap();"},{"Add":" let n = 100_000 as u64;"},{"Add":" let now = std::time::SystemTime::now();"},{"Add":" for i in 0..n {"},{"Add":" put(&mut txn, &mut db, &((i * i) % 1_000), &()).unwrap();"},{"Add":" }"},{"Add":" println!(\"moi: {:?}\", now.elapsed());"},{"Add":" let d = 10;"},{"Add":" for i in 0..d {"},{"Add":" // debug!(\"deleting {:?}\", (i*i)%1_000_000);"},{"Add":" del(&mut txn, &mut db, &((i * i) % 1_000_000), None).unwrap();"},{"Add":" }"},{"Add":" txn.commit().unwrap();"},{"Add":"}"},{"Add":""},{"Add":"#[test]"},{"Add":"pub fn last_cursor() {"},{"Add":" type B = btree::page::Page;"},{"Add":" env_logger::try_init().unwrap_or(());"},{"Add":" let env = Env::new_anon(409600000).unwrap();"},{"Add":" let mut txn = Env::mut_txn_begin(&env).unwrap();"},{"Add":" let mut db: Db<_, u64, (), B> = create_db(&mut txn).unwrap();"},{"Add":" let n = 100_000 as u64;"},{"Add":" let m = 10_000;"},{"Add":" let now = std::time::SystemTime::now();"},{"Add":" let mut max = 0;"},{"Add":" for i in 0..n {"},{"Add":" put(&mut txn, &mut db, &((i * i) % m), &()).unwrap();"},{"Add":" max = max.max((i * i) % m);"},{"Add":" }"},{"Add":""},{"Add":" let _db2 = fork_db(&mut txn, &db);"},{"Add":" debug!(\"{:?}\", now.elapsed());"},{"Add":" let mut curs = btree::cursor::Cursor::new(&db);"},{"Add":" let (&nn, _) = curs.set_last(&txn).unwrap().unwrap();"},{"Add":" assert_eq!(max, nn)"},{"Add":"}"},{"Add":""},{"Add":"#[test]"},{"Add":"pub fn fork() {"},{"Add":" type B = btree::page::Page;"},{"Add":" env_logger::try_init().unwrap_or(());"},{"Add":" let env = Env::new_anon(409600000).unwrap();"},{"Add":" let mut txn = Env::mut_txn_begin(&env).unwrap();"},{"Add":" let mut db: Db<_, u64, (), B> = create_db(&mut txn).unwrap();"},{"Add":" let n = 1000 as u64;"},{"Add":" let now = std::time::SystemTime::now();"},{"Add":" let mut values = Vec::with_capacity(n as usize);"},{"Add":" for i in 0..n - 1 {"},{"Add":" if put(&mut txn, &mut db, &i, &()).unwrap() {"},{"Add":" values.push(i);"},{"Add":" }"},{"Add":" }"},{"Add":" debug!(\"{:?}\", now.elapsed());"},{"Add":" let db2 = fork_db(&mut txn, &db).unwrap();"},{"Add":" debug::debug(&txn, &db2, \"debug_just\", true);"},{"Add":" let mut values2 = values.clone();"},{"Add":" values2.sort();"},{"Add":" for i in n - 1..n {"},{"Add":" if put(&mut txn, &mut db, &i, &()).unwrap() {"},{"Add":" values.push(i);"},{"Add":" }"},{"Add":" }"},{"Add":" values.sort();"},{"Add":""},{"Add":" debug::debug(&txn, &db, \"debug\", true);"},{"Add":" debug::debug(&txn, &db2, \"debug_forked\", true);"},{"Add":""},{"Add":" let mut curs = btree::cursor::Cursor::new(&db);"},{"Add":" let mut nn = 0;"},{"Add":" while let Some((k, _)) = curs.next(&mut txn).unwrap() {"},{"Add":" // debug!(\"{:?}\", k);"},{"Add":" assert_eq!(*k, values[nn]);"},{"Add":" nn += 1;"},{"Add":" }"},{"Add":""},{"Add":" let mut curs = btree::cursor::Cursor::new(&db);"},{"Add":" curs.set(&txn, Some((&500, Some(&())))).unwrap();"},{"Add":""},{"Add":" assert_eq!(nn, values.len());"},{"Add":" let mut curs = btree::cursor::Cursor::new(&db2);"},{"Add":" let mut nn = 0;"},{"Add":" while let Some((k, _)) = curs.next(&mut txn).unwrap() {"},{"Add":" assert_eq!(*k, values2[nn]);"},{"Add":" nn += 1;"},{"Add":" }"},{"Add":" assert_eq!(nn, values2.len());"},{"Add":""},{"Add":" let mut refs = BTreeMap::new();"},{"Add":" debug!(\"{:?} {:?}\", db, db2);"},{"Add":" add_refs(&txn, &db, &mut refs).unwrap();"},{"Add":" add_refs(&txn, &db2, &mut refs).unwrap();"},{"Add":" txn.commit().unwrap();"},{"Add":" let mut txn = Env::mut_txn_begin(&env).unwrap();"},{"Add":" if txn.free.offset > 0 {"},{"Add":" let db_free = Db {"},{"Add":" db: txn.free,"},{"Add":" marker: std::marker::PhantomData,"},{"Add":" };"},{"Add":" let mut curs: btree::cursor::Cursor = btree::cursor::Cursor::new(&db_free);"},{"Add":" debug!(\"{:?}\", db_free);"},{"Add":" while let Some((k, _)) = curs.next(&mut txn).unwrap() {"},{"Add":" debug!(\"free: {:?}\", k);"},{"Add":" }"},{"Add":" }"},{"Add":" debug!(\"{:?}\", refs);"},{"Add":"}"},{"Add":""},{"Add":"fn add_refs, V: Representable, P: BTreePage>("},{"Add":" txn: &T,"},{"Add":" db: &Db,"},{"Add":" pages: &mut BTreeMap,"},{"Add":") -> Result<(), T::Error> {"},{"Add":" let mut stack = vec![db.db];"},{"Add":" while let Some(p) = stack.pop() {"},{"Add":" match pages.entry(p.offset) {"},{"Add":" Entry::Vacant(e) => {"},{"Add":" e.insert(1);"},{"Add":" let mut c = P::first_cursor(p.as_page());"},{"Add":" let l = P::left_child(p.as_page(), &c);"},{"Add":" if l > 0 {"},{"Add":" stack.push(txn.load_page(l)?);"},{"Add":" while let Some((_, _, r)) = P::next(p.as_page(), &mut c) {"},{"Add":" stack.push(txn.load_page(r)?)"},{"Add":" }"},{"Add":" }"},{"Add":" }"},{"Add":" Entry::Occupied(mut e) => {"},{"Add":" e.insert(e.get() + 1);"},{"Add":" }"},{"Add":" }"},{"Add":" }"},{"Add":" Ok(())"},{"Add":"}"}]}}],"owner":"pijul","repo":"sanakirja","token":"h+0rr85oa9j6itLe8zklUkAUmZx7qW61VySAawB+iSg=","login":null}

…

Dependencies

Change contents