Skip to content

Commit 963e3ab

Browse files
committed
fix example
1 parent 399d518 commit 963e3ab

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

examples/kv/src/main.rs

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -138,12 +138,12 @@ impl KvStore {
138138
self.wal.truncate()?;
139139
}
140140

141-
if self.tree.first_level_segment_count() > 16 {
141+
if self.tree.level_segment_count(0).unwrap_or_default() > 16 {
142142
eprintln!("Stalling writes...");
143143
std::thread::sleep(Duration::from_millis(100));
144144
}
145145

146-
while self.tree.first_level_segment_count() > 20 {
146+
while self.tree.level_segment_count(0).unwrap_or_default() > 20 {
147147
eprintln!("Halting writes until L0 is cleared up...");
148148
}
149149

0 commit comments

Comments
 (0)