@@ -54,9 +54,13 @@ fn main() -> Result<()> {
|
|||||||
}
|
}
|
||||||
} else if line == "flush" {
|
} else if line == "flush" {
|
||||||
lsm.force_flush_imm_memtables()?;
|
lsm.force_flush_imm_memtables()?;
|
||||||
|
} else if line == "quit" {
|
||||||
|
lsm.close()?;
|
||||||
|
break;
|
||||||
} else {
|
} else {
|
||||||
println!("invalid command: {}", line);
|
println!("invalid command: {}", line);
|
||||||
}
|
}
|
||||||
epoch += 1;
|
epoch += 1;
|
||||||
}
|
}
|
||||||
|
Ok(())
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user