maokaihe/mini_lsm
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

improve compaction concat iterator tests

Browse Source 
Signed-off-by: Alex Chi <iskyzh@gmail.com>
This commit is contained in:
Alex Chi
2024-01-30 18:18:55 +08:00
parent 348eb01fb1
commit 770400d983
2 changed files with 3 additions and 17 deletions
Download Patch File Download Diff File Expand all files Collapse all files

14
mini-lsm-mvcc/src/compact/leveled.rs
View File

@@ -119,20 +119,6 @@ impl LeveledCompactionController {
} }
priorities.sort_by(|a, b| a.partial_cmp(b).unwrap().reverse()); priorities.sort_by(|a, b| a.partial_cmp(b).unwrap().reverse());
println!(
"target level sizes: {:?}, real level sizes: {:?}, base_level: {}",
target_level_size
.iter()
.map(|x| format!("{:.3}MB", *x as f64 / 1024.0 / 1024.0))
.collect::<Vec<_>>(),
real_level_size
.iter()
.map(|x| format!("{:.3}MB", *x as f64 / 1024.0 / 1024.0))
.collect::<Vec<_>>(),
base_level,
);
println!("compaction triggered by priority: {:?}", priorities);
let priority = priorities.first(); let priority = priorities.first();
if let Some((_, level)) = priority { if let Some((_, level)) = priority {
println!( println!(

6
mini-lsm/src/tests/harness.rs
View File

@@ -327,7 +327,7 @@ pub fn check_compaction_ratio(storage: Arc<MiniLsm>) {
} }
assert!( assert!(
num_iters <= l0_sst_num + num_memtables + max_levels, num_iters <= l0_sst_num + num_memtables + max_levels,
"did you use concat iterators?" "we found {num_iters} iterators in your implementation, (l0_sst_num={l0_sst_num}, num_memtables={num_memtables}, max_levels={max_levels}) did you use concat iterators?"
); );
} }
CompactionOptions::Leveled(LeveledCompactionOptions { CompactionOptions::Leveled(LeveledCompactionOptions {
@@ -355,7 +355,7 @@ pub fn check_compaction_ratio(storage: Arc<MiniLsm>) {
} }
assert!( assert!(
num_iters <= l0_sst_num + num_memtables + max_levels, num_iters <= l0_sst_num + num_memtables + max_levels,
"did you use concat iterators?" "we found {num_iters} iterators in your implementation, (l0_sst_num={l0_sst_num}, num_memtables={num_memtables}, max_levels={max_levels}) did you use concat iterators?"
); );
} }
CompactionOptions::Tiered(TieredCompactionOptions { CompactionOptions::Tiered(TieredCompactionOptions {
@@ -397,7 +397,7 @@ pub fn check_compaction_ratio(storage: Arc<MiniLsm>) {
} }
assert!( assert!(
num_iters <= num_memtables + num_tiers, num_iters <= num_memtables + num_tiers,
"did you use concat iterators?" "we found {num_iters} iterators in your implementation, (num_memtables={num_memtables}, num_tiers={num_tiers}) did you use concat iterators?"
); );
} }
} }