mirror of
https://github.com/quickwit-oss/tantivy.git
synced 2026-01-04 08:12:54 +00:00
Compare commits
1 Commits
range
...
remove-tru
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
4fc8712f1a |
@@ -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(
|
||||||
|
|||||||
@@ -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
|
||||||
|
|||||||
Reference in New Issue
Block a user