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

Apply review suggestions

Browse Source
This commit is contained in:
Loïc Lecrenier 2022-10-27 16:23:50 +02:00
parent 4f4fc20acf
commit 2c31d7c50a
1 changed files with 5 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -100,7 +100,7 @@ pub struct Query {
} }
impl Query { impl Query {
/// Return `true` iff every field of the query is set to `None`, such that the query /// Return `true` if every field of the query is set to `None`, such that the query
/// matches all tasks. /// matches all tasks.
pub fn is_empty(&self) -> bool { pub fn is_empty(&self) -> bool {
matches!( matches!(
@ -569,9 +569,7 @@ impl IndexScheduler {
let rtxn = self.env.read_txn()?; let rtxn = self.env.read_txn()?;
let processing_tasks = self.processing_tasks.read().unwrap().processing.clone(); let processing_tasks = self.processing_tasks.read().unwrap().processing.clone();
let index_tasks = self.index_tasks(&rtxn, index)?; let index_tasks = self.index_tasks(&rtxn, index)?;
let nbr_index_processing_tasks = processing_tasks.intersection_len(&index_tasks); let nbr_index_processing_tasks = processing_tasks.intersection_len(&index_tasks);
Ok(nbr_index_processing_tasks > 0) Ok(nbr_index_processing_tasks > 0)
} }
@ -582,7 +580,7 @@ impl IndexScheduler {
/// ///
/// 1. IndexSwap tasks are not publicly associated with any index, but they are associated /// 1. IndexSwap tasks are not publicly associated with any index, but they are associated
/// with many indexes internally. /// with many indexes internally.
/// 2. The user may not have the rights to access the tasks (internally) associated wuth all indexes. /// 2. The user may not have the rights to access the tasks (internally) associated with all indexes.
pub fn get_task_ids_from_authorized_indexes( pub fn get_task_ids_from_authorized_indexes(
&self, &self,
rtxn: &RoTxn, rtxn: &RoTxn,
@ -601,8 +599,8 @@ impl IndexScheduler {
// must be discarded. // must be discarded.
if let Some(authorized_indexes) = authorized_indexes { if let Some(authorized_indexes) = authorized_indexes {
let all_indexes_iter = self.index_tasks.iter(rtxn)?; let all_indexes_iter = self.index_tasks.iter(rtxn)?;
for iter_el in all_indexes_iter { for result in all_indexes_iter {
let (index, index_tasks) = iter_el?; let (index, index_tasks) = result?;
if !authorized_indexes.contains(&index.to_owned()) { if !authorized_indexes.contains(&index.to_owned()) {
tasks -= index_tasks; tasks -= index_tasks;
} }
@ -619,7 +617,7 @@ impl IndexScheduler {
/// ///
/// 1. IndexSwap tasks are not publicly associated with any index, but they are associated /// 1. IndexSwap tasks are not publicly associated with any index, but they are associated
/// with many indexes internally. /// with many indexes internally.
/// 2. The user may not have the rights to access the tasks (internally) associated wuth all indexes. /// 2. The user may not have the rights to access the tasks (internally) associated with all indexes.
pub fn get_tasks_from_authorized_indexes( pub fn get_tasks_from_authorized_indexes(
&self, &self,
query: Query, query: Query,