From 6ee65d83d983ecc35f596f516d2739e7a91b9efa Mon Sep 17 00:00:00 2001 From: Determinant Date: Tue, 16 Jun 2020 18:03:12 -0400 Subject: improve WALLoader; verify CRC32 --- tests/common/mod.rs | 15 +++++++++------ 1 file changed, 9 insertions(+), 6 deletions(-) (limited to 'tests/common') diff --git a/tests/common/mod.rs b/tests/common/mod.rs index b61233b..247b2ee 100644 --- a/tests/common/mod.rs +++ b/tests/common/mod.rs @@ -3,7 +3,7 @@ #[allow(dead_code)] use async_trait::async_trait; use growthring::wal::{ - WALBytes, WALFile, WALLoader, WALPos, WALRingId, WALStore, + WALBytes, WALFile, WALLoader, WALPos, WALRingId, WALStore, RecoverPolicy }; use indexmap::{map::Entry, IndexMap}; use rand::Rng; @@ -531,15 +531,14 @@ impl PaintingSim { &self, state: &mut WALStoreEmulState, canvas: &mut Canvas, - wal: WALLoader, + loader: WALLoader, ops: &mut Vec, ringid_map: &mut HashMap, fgen: Rc, ) -> Result<(), ()> { let mut rng = ::seed_from_u64(self.seed); - let mut wal = - wal.recover(WALStoreEmul::new(state, fgen.clone(), |_, _| {}))?; + let mut wal = loader.load(WALStoreEmul::new(state, fgen.clone(), |_, _| {}))?; for _ in 0..self.n { let pss = (0..self.m) .map(|_| { @@ -597,7 +596,11 @@ impl PaintingSim { } pub fn get_walloader(&self) -> WALLoader { - WALLoader::new(self.file_nbit, self.block_nbit, self.file_cache) + let mut loader = WALLoader::new(); + loader.file_nbit(self.file_nbit) + .block_nbit(self.block_nbit) + .cache_size(self.file_cache); + loader } pub fn get_nticks(&self, state: &mut WALStoreEmulState) -> usize { @@ -631,7 +634,7 @@ impl PaintingSim { let mut last_idx = 0; let mut napplied = 0; canvas.clear_queued(); - wal.recover(WALStoreEmul::new( + wal.load(WALStoreEmul::new( state, Rc::new(ZeroFailGen), |payload, ringid| { -- cgit v1.2.3-70-g09d2