Compare commits

...

1 Commits

Author SHA1 Message Date
Paul Masurel
4fc8712f1a SegmentUpdater.add_segment does not need to return true 2019-11-09 20:30:40 +09:00
2 changed files with 3 additions and 4 deletions

View File

@@ -227,7 +227,8 @@ fn index_documents(
delete_cursor, delete_cursor,
delete_bitset_opt, delete_bitset_opt,
); );
Ok(segment_updater.add_segment(segment_entry)) segment_updater.add_segment(segment_entry);
Ok(true)
} }
fn apply_deletes( fn apply_deletes(

View File

@@ -199,14 +199,12 @@ impl SegmentUpdater {
self.0.pool.spawn_fn(move || Ok(f(me_clone))) self.0.pool.spawn_fn(move || Ok(f(me_clone)))
} }
pub fn add_segment(&self, segment_entry: SegmentEntry) -> bool { pub fn add_segment(&self, segment_entry: SegmentEntry) {
self.run_async(|segment_updater| { self.run_async(|segment_updater| {
segment_updater.0.segment_manager.add_segment(segment_entry); segment_updater.0.segment_manager.add_segment(segment_entry);
segment_updater.consider_merge_options(); segment_updater.consider_merge_options();
true
}) })
.forget(); .forget();
true
} }
/// Orders `SegmentManager` to remove all segments /// Orders `SegmentManager` to remove all segments