2830: Increase max concurrent readers on indexes r=irevoire a=arriven

# Pull Request

## What does this PR do?
Fixes #2786 
<!-- Please link the issue you're trying to fix with this PR, if none then please create an issue first. -->

## PR checklist
Please check if your PR fulfills the following requirements:
- [x] Does this PR fix an existing issue?
- [x] Have you read the contributing guidelines?
- [x] Have you made sure that the title is accurate and descriptive of the changes?

Thank you so much for contributing to Meilisearch!


Co-authored-by: arriven <20084245+Arriven@users.noreply.github.com>
This commit is contained in:
bors[bot] 2022-10-03 17:26:45 +00:00 committed by GitHub
commit 8fa8eb9767
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
3 changed files with 3 additions and 0 deletions

View File

@ -105,6 +105,7 @@ impl Index {
let mut options = EnvOpenOptions::new(); let mut options = EnvOpenOptions::new();
options.map_size(size); options.map_size(size);
options.max_readers(1024);
let index = milli::Index::new(options, &dst_dir_path)?; let index = milli::Index::new(options, &dst_dir_path)?;
let mut txn = index.write_txn()?; let mut txn = index.write_txn()?;

View File

@ -94,6 +94,7 @@ impl Index {
create_dir_all(&path)?; create_dir_all(&path)?;
let mut options = EnvOpenOptions::new(); let mut options = EnvOpenOptions::new();
options.map_size(size); options.map_size(size);
options.max_readers(1024);
let inner = Arc::new(milli::Index::new(options, &path)?); let inner = Arc::new(milli::Index::new(options, &path)?);
Ok(Index { Ok(Index {
inner, inner,

View File

@ -181,6 +181,7 @@ impl SnapshotJob {
let mut options = milli::heed::EnvOpenOptions::new(); let mut options = milli::heed::EnvOpenOptions::new();
options.map_size(self.index_size); options.map_size(self.index_size);
options.max_readers(1024);
let index = milli::Index::new(options, entry.path())?; let index = milli::Index::new(options, entry.path())?;
index.copy_to_path(dst, CompactionOption::Enabled)?; index.copy_to_path(dst, CompactionOption::Enabled)?;
} }