snowykami/meilisearch
1
0
Fork 0
mirror of https://github.com/meilisearch/meilisearch.git synced 2024-11-23 10:37:41 +08:00
Code Issues Actions 3 Packages Projects Releases Wiki Activity

feat: Fetch doc indexes while there is time

Browse Source
This commit is contained in:
Clément Renault 2019-08-16 15:01:25 +02:00
parent bb0a79c577
commit d9c9fafd78
No known key found for this signature in database
GPG Key ID: 0151CDAB43460DAE
1 changed files with 9 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
meilidb-core/src/query_builder.rs
View File

@ -1,7 +1,7 @@
use std::hash::Hash; use std::hash::Hash;
use std::ops::Range; use std::ops::Range;
use std::rc::Rc; use std::rc::Rc;
use std::time::Instant; use std::time::{Instant, Duration};
use std::{mem, cmp, cmp::Reverse}; use std::{mem, cmp, cmp::Reverse};
use fst::{Streamer, IntoStreamer}; use fst::{Streamer, IntoStreamer};
@ -325,10 +325,11 @@ where S: Store,
let mut matches = Vec::new(); let mut matches = Vec::new();
let mut highlights = Vec::new(); let mut highlights = Vec::new();
let mut query_db = std::time::Duration::default(); let fetching_end_time = Instant::now() + Duration::from_millis(30);
let mut query_db = Duration::default();
let start = Instant::now(); let start = Instant::now();
for automaton in automatons { 'automatons: for automaton in automatons {
let Automaton { index, is_exact, query_len, dfa, .. } = automaton; let Automaton { index, is_exact, query_len, dfa, .. } = automaton;
let mut stream = words.search(&dfa).into_stream(); let mut stream = words.search(&dfa).into_stream();
@ -345,6 +346,11 @@ where S: Store,
query_db += start.elapsed(); query_db += start.elapsed();
for di in doc_indexes.as_slice() { for di in doc_indexes.as_slice() {
if Instant::now() > fetching_end_time {
break 'automatons
}
let attribute = searchables.map_or(Some(di.attribute), |r| r.get(di.attribute)); let attribute = searchables.map_or(Some(di.attribute), |r| r.get(di.attribute));
if let Some(attribute) = attribute { if let Some(attribute) = attribute {
let match_ = TmpMatch { let match_ = TmpMatch {