Tests++ (including UUID)

[?]

Feb 6, 2021, 2:08 PM

EYNN7RLSFVBWDLRTLNNFUAF46Q6OX3BR5SUEJIOOHBSNP7FVBXGAC

Dependencies

[2] KX3WVNZW Testing/debugging "rebalance causes split of the root"
[3] 6UVFCERM Formatting, debugging, etc.
[*] UAQX27N4 Tests

Change contents

replacement in sanakirja/src/tests.rs at line 579

[2.3674]→[2.3674:3694](∅→∅)

fn split_on_del() {

[2.3674]

[2.3694]

fn split_on_del1() {
replacement in sanakirja/src/tests.rs at line 589

[2.4099]→[2.4099:4164](∅→∅)

put(&mut txn, &mut db, &(i + 9), &[b'b'; 254]).unwrap();

[2.4099]

[2.4164]

put(&mut txn, &mut db, &(i + 9), &[b'b'; 250]).unwrap();
replacement in sanakirja/src/tests.rs at line 597

[2.4344]→[2.4344:4468](∅→∅)

crate::debug::debug(&txn, &[&db], "debug0", true);
for i in 0..4 {
debug!("============ deleting {:?}", i);

[2.4344]

[2.4468]

for i in 0..3 {
replacement in sanakirja/src/tests.rs at line 600

[2.4525]→[2.4525:4682](∅→∅)

crate::debug::debug(&txn, &[&db], "debug1", true);
del(&mut txn, &mut db, &4, None).unwrap();
crate::debug::debug(&txn, &[&db], "debug2", true);

[2.4525]

[2.4682]

assert_eq!(
depth::<_, u64, [u8], UP<u64, [u8]>>(&txn, db.db).unwrap(),
2
);
del(&mut txn, &mut db, &3, None).unwrap();
assert_eq!(
depth::<_, u64, [u8], UP<u64, [u8]>>(&txn, db.db).unwrap(),
3
);
}

fn depth<
T: LoadPage,
K: Representable + ?Sized + std::fmt::Debug,
V: Representable + ?Sized + std::fmt::Debug,
P: btree::BTreePage<K, V>,
>(
txn: &T,
mut p: CowPage,
) -> Result<usize, T::Error> {
let mut n = 1;
loop {
let cursor = P::first_cursor(p.as_page());
let l = P::left_child(p.as_page(), &cursor);
if l == 0 {
return Ok(n);
}
p = txn.load_page(l)?;
n += 1;
}
edit in sanakirja/src/tests.rs at line 651

[2.5364]→[2.5364:5419](∅→∅)

crate::debug::debug(&txn, &[&db], "debug0", true);
replacement in sanakirja/src/tests.rs at line 652

[2.5466]→[2.5466:5521](∅→∅)

crate::debug::debug(&txn, &[&db], "debug1", true);

[2.5466]

[2.5521]

}

#[test]
fn lmdb_uuid() {
use lmdb_rs::*;
env_logger::try_init().unwrap_or(());
for i in 1..8 {
let n = i * 1_000_000;
std::fs::remove_dir_all("/tmp/sanakirja0").unwrap_or(());
std::fs::create_dir_all("/tmp/sanakirja0").unwrap();

let env = Env::new("/tmp/sanakirja0", 409_600_000, 2).unwrap();
let mut txn = Env::mut_txn_begin(&env).unwrap();

let mut db =
create_db_::<MutTxn<&Env, ()>, uuid::Bytes, u64, P<uuid::Bytes, u64>>(&mut txn)
.unwrap();

let mut times = [0f64; 4];

let mut test = Vec::with_capacity(n);
for i in 0..n {
let uuid = uuid::Uuid::new_v4();
test.push((uuid, i))
}
let now = std::time::SystemTime::now();
for (k, v) in test.iter() {
assert!(put(&mut txn, &mut db, k.as_bytes(), &(*v as u64)).unwrap());
}
times[0] = now.elapsed().unwrap().as_secs_f64();
let now = std::time::SystemTime::now();
for (k, v) in test.iter() {
assert_eq!(
btree::get(&txn, &db, k.as_bytes(), None).unwrap(),
Some((k.as_bytes(), &(*v as u64)))
)
}
times[1] = now.elapsed().unwrap().as_secs_f64();

std::fs::remove_dir_all("/tmp/test-lmdb").unwrap_or(());
std::fs::create_dir_all("/tmp/test-lmdb").unwrap_or(());
let env = EnvBuilder::new()
.map_size(1 << 30)
.open("/tmp/test-lmdb", 0o777)
.unwrap();

let db_handle = env.get_default_db(lmdb_rs::DbFlags::empty()).unwrap();
let txn = env.new_transaction().unwrap();
{
let db = txn.bind(&db_handle);
let now = std::time::SystemTime::now();
for (k, v) in test.iter() {
let k = lmdb_rs::MDB_val {
mv_size: 16,
mv_data: k.as_bytes().as_ptr() as *const libc::c_void,
};
db.set(&k, &(*v as u64)).unwrap();
}
times[2] = now.elapsed().unwrap().as_secs_f64();
}
match txn.commit() {
Err(_) => panic!("failed to commit!"),
Ok(_) => (),
}

let reader = env.get_reader().unwrap();
let db = reader.bind(&db_handle);
let now = std::time::SystemTime::now();
for (k, v) in test.iter() {
let k = lmdb_rs::MDB_val {
mv_size: 16,
mv_data: k.as_bytes().as_ptr() as *const libc::c_void,
};
let name = db.get::<u64>(&k).ok();
assert_eq!(name, Some(*v as u64))
}
times[3] = now.elapsed().unwrap().as_secs_f64();

print!("{}", n);
for t in times.iter() {
print!(", {}", t)
}
println!();
}