searchengines-web/MeiliSearch
searchengines-web/MeiliSearch
1
0
Fork 0
mirror of https://github.com/meilisearch/MeiliSearch synced 2024-11-26 23:04:26 +01:00
Code Issues Releases Wiki Activity

fix the index creation

Browse Source
This commit is contained in:
Irevoire 2022-10-21 13:58:58 +02:00 committed by Clément Renault
parent 32cfac0cfd
commit 50386921df
No known key found for this signature in database
GPG Key ID: 92ADA4E935E71FA4
1 changed files with 12 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -1,6 +1,6 @@
use std::collections::hash_map::Entry; use std::collections::hash_map::Entry;
use std::collections::HashMap; use std::collections::HashMap;
use std::path::PathBuf; use std::path::{Path, PathBuf};
use std::sync::{Arc, RwLock}; use std::sync::{Arc, RwLock};
use std::{fs, thread}; use std::{fs, thread};
@ -63,6 +63,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) -> Result<Index> {
let mut options = EnvOpenOptions::new();
options.map_size(self.index_size);
options.max_readers(1024);
Ok(Index::new(options, path)?)
}
/// Get or create the index. /// Get or create the index.
pub fn create_index(&self, wtxn: &mut RwTxn, name: &str) -> Result<Index> { pub fn create_index(&self, wtxn: &mut RwTxn, name: &str) -> Result<Index> {
match self.index(wtxn, name) { match self.index(wtxn, name) {
@ -73,10 +82,7 @@ impl IndexMapper {
let index_path = self.base_path.join(uuid.to_string()); let index_path = self.base_path.join(uuid.to_string());
fs::create_dir_all(&index_path)?; fs::create_dir_all(&index_path)?;
let mut options = EnvOpenOptions::new(); self.create_or_open_index(&index_path)
options.map_size(self.index_size);
options.max_readers(1024);
Ok(Index::new(options, &index_path)?)
} }
error => error, error => error,
} }
@ -156,10 +162,7 @@ impl IndexMapper {
match index_map.entry(uuid) { match index_map.entry(uuid) {
Entry::Vacant(entry) => { Entry::Vacant(entry) => {
let index_path = self.base_path.join(uuid.to_string()); let index_path = self.base_path.join(uuid.to_string());
fs::create_dir_all(&index_path)?; let index = self.create_or_open_index(&index_path)?;
let mut options = EnvOpenOptions::new();
options.map_size(self.index_size);
let index = Index::new(options, &index_path)?;
entry.insert(Available(index.clone())); entry.insert(Available(index.clone()));
index index
} }