snowykami/meilisearch
1
0
Fork 0
mirror of https://github.com/meilisearch/meilisearch.git synced 2024-11-22 18:17:39 +08:00
Code Issues Actions 9 Packages Projects Releases Wiki Activity

Apply Rustfmt

Browse Source
This commit is contained in:
amab8901 2022-12-19 19:24:56 +01:00
parent b4a73f2d74
commit aa03e02fdc
2 changed files with 13 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
index-scheduler/src/index_mapper.rs
View File

@ -66,11 +66,15 @@ impl IndexMapper {
/// Create or open an index in the specified path.
/// The path *must* exists or an error will be thrown.
fn create_or_open_index(&self, path: &Path, date: Option<(time::OffsetDateTime, time::OffsetDateTime)>) -> Result<Index> {
fn create_or_open_index(
&self,
path: &Path,
date: Option<(time::OffsetDateTime, time::OffsetDateTime)>,
) -> Result<Index> {
let mut options = EnvOpenOptions::new();
options.map_size(clamp_to_page_size(self.index_size));
options.max_readers(1024);
if date == None {
Ok(Index::new(options, path)?)
} else {
@ -80,7 +84,12 @@ impl IndexMapper {
}
/// Get or create the index.
pub fn create_index(&self, mut wtxn: RwTxn, name: &str, date: Option<(time::OffsetDateTime, time::OffsetDateTime)>) -> Result<Index> {
pub fn create_index(
&self,
mut wtxn: RwTxn,
name: &str,
date: Option<(time::OffsetDateTime, time::OffsetDateTime)>,
) -> Result<Index> {
match self.index(&wtxn, name) {
Ok(index) => {
wtxn.commit()?;

2
index-scheduler/src/lib.rs
View File

@ -867,7 +867,7 @@ impl IndexScheduler {
/// Create a new index without any associated task.
pub fn create_raw_index(&self, name: &str) -> Result<Index> {
let wtxn = self.env.write_txn()?;
let date = Some(( time::OffsetDateTime::now_utc(), time::OffsetDateTime::now_utc() ));
let date = Some((time::OffsetDateTime::now_utc(), time::OffsetDateTime::now_utc()));
let index = self.index_mapper.create_index(wtxn, name, date)?;
Ok(index)