From 350f2638cb3e15df231381b8fd286595058b7a54 Mon Sep 17 00:00:00 2001 From: Determinant Date: Wed, 10 Jun 2020 22:50:38 -0400 Subject: add closure to WALStoreEmul --- tests/rand_fail.rs | 11 ++++++----- 1 file changed, 6 insertions(+), 5 deletions(-) (limited to 'tests/rand_fail.rs') diff --git a/tests/rand_fail.rs b/tests/rand_fail.rs index 0cd519c..6c2c3c1 100644 --- a/tests/rand_fail.rs +++ b/tests/rand_fail.rs @@ -41,21 +41,22 @@ fn run(n: usize, m: usize, k: usize, Ok(()) } -fn check(canvas: &mut Canvas, wal: &mut WALLoader, trace: &Vec) -> bool { +fn check(canvas: &mut Canvas, wal: &mut WALLoader, trace: &Vec) -> bool { true } #[test] fn test_rand_fail() { - let fgen = SingleFailGen::new(100000); + let fgen = SingleFailGen::new(100); let n = 100; let m = 10; let k = 100; let mut rng = rand::thread_rng(); let mut state = WALStoreEmulState::new(); - let mut wal = WALLoader::new(WALStoreEmul::new(&mut state, fgen), 9, 8, 1000).recover().unwrap(); + let mut wal = WALLoader::new(WALStoreEmul::new(&mut state, fgen, |_, _|{}), 9, 8, 1000).recover().unwrap(); let mut trace: Vec = Vec::new(); let mut canvas = Canvas::new(1000); - run(n, m, k, &mut canvas, &mut wal, &mut trace, &mut rng).unwrap(); - WALLoader::new(common::WALStoreEmul::new(&mut state, common::ZeroFailGen), 9, 8, 1000).recover().unwrap(); + run(n, m, k, &mut canvas, &mut wal, &mut trace, &mut rng); //.unwrap(); + let mut wal = WALLoader::new(WALStoreEmul::new(&mut state, common::ZeroFailGen, |payload, wal_off|{}), 9, 8, 1000); + assert!(check(&mut canvas, &mut wal, &trace)); } -- cgit v1.2.3-70-g09d2