diff options
author | Paul Masurel <paul.masurel@gmail.com> | 2019-01-28 12:37:55 +0100 |
---|---|---|
committer | Paul Masurel <paul.masurel@gmail.com> | 2019-01-28 12:37:55 +0100 |
commit | 7b97dde3356dc1ac61887ef64b0d53e296d94e57 (patch) | |
tree | fce910714b33715d60673042f2cfc09be33e2c4e /src/indexer | |
parent | 644b4bd0a1dc98be434fe268cea1bccd81ec0f22 (diff) |
Clippy + cargo fmt
Diffstat (limited to 'src/indexer')
-rw-r--r-- | src/indexer/index_writer.rs | 11 | ||||
-rw-r--r-- | src/indexer/segment_register.rs | 4 |
2 files changed, 8 insertions, 7 deletions
diff --git a/src/indexer/index_writer.rs b/src/indexer/index_writer.rs index 13daade..d2a2f02 100644 --- a/src/indexer/index_writer.rs +++ b/src/indexer/index_writer.rs @@ -9,9 +9,11 @@ use core::SegmentId; use core::SegmentMeta; use core::SegmentReader; use crossbeam::channel; +use directory::DirectoryLock; use docset::DocSet; use error::TantivyError; use fastfield::write_delete_bitset; +use futures::{Canceled, Future}; use indexer::delete_queue::{DeleteCursor, DeleteQueue}; use indexer::doc_opstamp_mapping::DocToOpstampMapping; use indexer::operation::DeleteOperation; @@ -28,8 +30,6 @@ use std::sync::Arc; use std::thread; use std::thread::JoinHandle; use Result; -use directory::DirectoryLock; -use futures::{Future, Canceled}; // Size of the margin for the heap. A segment is closed when the remaining memory // in the heap goes below MARGIN_IN_BYTES. @@ -459,7 +459,10 @@ impl IndexWriter { /// Merges a given list of segments /// /// `segment_ids` is required to be non-empty. - pub fn merge(&mut self, segment_ids: &[SegmentId]) -> Result<impl Future<Item=SegmentMeta, Error=Canceled>> { + pub fn merge( + &mut self, + segment_ids: &[SegmentId], + ) -> Result<impl Future<Item = SegmentMeta, Error = Canceled>> { self.segment_updater.start_merge(segment_ids) } @@ -652,12 +655,12 @@ impl IndexWriter { mod tests { use super::initial_table_size; + use directory::error::LockError; use error::*; use indexer::NoMergePolicy; use schema::{self, Document}; use Index; use Term; - use directory::error::LockError; #[test] fn test_lockfile_stops_duplicates() { diff --git a/src/indexer/segment_register.rs b/src/indexer/segment_register.rs index 2133989..74234f2 100644 --- a/src/indexer/segment_register.rs +++ b/src/indexer/segment_register.rs @@ -76,9 +76,7 @@ impl SegmentRegister { } pub fn get(&self, segment_id: &SegmentId) -> Option<SegmentEntry> { - self.segment_states - .get(segment_id) - .map(|segment_entry| segment_entry.clone()) + self.segment_states.get(segment_id).cloned() } pub fn new(segment_metas: Vec<SegmentMeta>, delete_cursor: &DeleteCursor) -> SegmentRegister { |