summaryrefslogtreecommitdiffstats
path: root/src/indexer
diff options
context:
space:
mode:
authorPaul Masurel <paul.masurel@gmail.com>2019-01-28 12:37:55 +0100
committerPaul Masurel <paul.masurel@gmail.com>2019-01-28 12:37:55 +0100
commit7b97dde3356dc1ac61887ef64b0d53e296d94e57 (patch)
treefce910714b33715d60673042f2cfc09be33e2c4e /src/indexer
parent644b4bd0a1dc98be434fe268cea1bccd81ec0f22 (diff)
Clippy + cargo fmt
Diffstat (limited to 'src/indexer')
-rw-r--r--src/indexer/index_writer.rs11
-rw-r--r--src/indexer/segment_register.rs4
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 {