snowykami/meilisearch
1
0
Fork 0
mirror of https://github.com/meilisearch/meilisearch.git synced 2024-11-26 20:15:07 +08:00
Code Issues Actions 4 Packages Projects Releases Wiki Activity

create_or_open_index takes a map_size argument

Browse Source
This commit is contained in:
Louis Dureuil 2023-01-09 09:34:46 +01:00
parent 4c519c2ab3
commit faf1e17a27
No known key found for this signature in database
1 changed files with 5 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -71,9 +71,10 @@ impl IndexMapper {
&self, &self,
path: &Path, path: &Path,
date: Option<(OffsetDateTime, OffsetDateTime)>, date: Option<(OffsetDateTime, OffsetDateTime)>,
map_size: usize,
) -> Result<Index> { ) -> Result<Index> {
let mut options = EnvOpenOptions::new(); let mut options = EnvOpenOptions::new();
options.map_size(clamp_to_page_size(self.index_size)); options.map_size(clamp_to_page_size(map_size));
options.max_readers(1024); options.max_readers(1024);
if let Some((created, updated)) = date { if let Some((created, updated)) = date {
@ -102,7 +103,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 index = self.create_or_open_index(&index_path, date)?; let index = self.create_or_open_index(&index_path, date, self.index_size)?;
wtxn.commit()?; wtxn.commit()?;
// TODO: it would be better to lazily create the index. But we need an Index::open function for milli. // TODO: it would be better to lazily create the index. But we need an Index::open function for milli.
@ -196,7 +197,8 @@ impl IndexMapper {
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());
let index = self.create_or_open_index(&index_path, None)?; let index =
self.create_or_open_index(&index_path, None, self.index_size)?;
entry.insert(Available(index.clone())); entry.insert(Available(index.clone()));
index index
} }