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

fix compaction task info header

Browse Source 
Signed-off-by: Alex Chi <iskyzh@gmail.com>
This commit is contained in:
Alex Chi
2024-01-18 14:55:43 +08:00
parent 693e7f2e6a
commit 22491094cb
1 changed files with 12 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

16
mini-lsm/src/bin/compaction_simulator.rs
View File

@@ -241,8 +241,10 @@ fn main() {
storage.dump_original_id(true, false); storage.dump_original_id(true, false);
} }
let mut num_compactions = 0; let mut num_compactions = 0;
while let Some(task) = controller.generate_compaction_task(&storage.snapshot) { while let Some(task) = {
println!("--- Compaction Task ---"); println!("--- Compaction Task ---");
controller.generate_compaction_task(&storage.snapshot)
} {
let mut sst_ids = Vec::new(); let mut sst_ids = Vec::new();
for file in task for file in task
.upper_level_sst_ids .upper_level_sst_ids
@@ -339,7 +341,10 @@ fn main() {
} }
println!("--- Compaction Task ---"); println!("--- Compaction Task ---");
let mut num_compactions = 0; let mut num_compactions = 0;
while let Some(task) = controller.generate_compaction_task(&storage.snapshot) { while let Some(task) = {
println!("--- Compaction Task ---");
controller.generate_compaction_task(&storage.snapshot)
} {
let mut sst_ids = Vec::new(); let mut sst_ids = Vec::new();
for (tier_id, files) in &task.tiers { for (tier_id, files) in &task.tiers {
for file in files { for file in files {
@@ -440,7 +445,10 @@ fn main() {
storage.dump_original_id(false, true); storage.dump_original_id(false, true);
} }
let mut num_compactions = 0; let mut num_compactions = 0;
while let Some(task) = controller.generate_compaction_task(&storage.snapshot) { while let Some(task) = {
println!("--- Compaction Task ---");
controller.generate_compaction_task(&storage.snapshot)
} {
let mut sst_ids = Vec::new(); let mut sst_ids = Vec::new();
let split_num = task.upper_level_sst_ids.len() + task.lower_level_sst_ids.len(); let split_num = task.upper_level_sst_ids.len() + task.lower_level_sst_ids.len();
let mut first_keys = Vec::new(); let mut first_keys = Vec::new();
@@ -529,7 +537,7 @@ fn main() {
storage.dump_original_id(true, true); storage.dump_original_id(true, true);
} }
num_compactions += 1; num_compactions += 1;
if num_compactions >= storage.file_list.len() * max_levels { if num_compactions >= level0_file_num_compaction_trigger * max_levels * 2 {
panic!("compaction does not converge?"); panic!("compaction does not converge?");
} }
} }