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

remove the unused variants from the autobatcher

Browse Source
This commit is contained in:
Tamo 2022-10-19 12:52:20 +02:00 committed by Clément Renault
parent ab8f1c2865
commit cff003c928
No known key found for this signature in database
GPG Key ID: 92ADA4E935E71FA4
2 changed files with 7 additions and 16 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

22
index-scheduler/src/autobatcher.rs
View File

@ -22,10 +22,6 @@ enum AutobatchKind {
IndexDeletion, IndexDeletion,
IndexUpdate, IndexUpdate,
IndexSwap, IndexSwap,
TaskCancelation,
TaskDeletion,
DumpExport,
Snapshot,
} }
impl AutobatchKind { impl AutobatchKind {
@ -62,10 +58,12 @@ impl From<KindWithContent> for AutobatchKind {
KindWithContent::IndexCreation { .. } => AutobatchKind::IndexCreation, KindWithContent::IndexCreation { .. } => AutobatchKind::IndexCreation,
KindWithContent::IndexUpdate { .. } => AutobatchKind::IndexUpdate, KindWithContent::IndexUpdate { .. } => AutobatchKind::IndexUpdate,
KindWithContent::IndexSwap { .. } => AutobatchKind::IndexSwap, KindWithContent::IndexSwap { .. } => AutobatchKind::IndexSwap,
KindWithContent::TaskCancelation { .. } => AutobatchKind::TaskCancelation, KindWithContent::TaskCancelation { .. }
KindWithContent::TaskDeletion { .. } => AutobatchKind::TaskDeletion, | KindWithContent::TaskDeletion { .. }
KindWithContent::DumpExport { .. } => AutobatchKind::DumpExport, | KindWithContent::DumpExport { .. }
KindWithContent::Snapshot => AutobatchKind::Snapshot, | KindWithContent::Snapshot => {
panic!("The autobatcher should never be called with tasks that don't apply to an index.")
}
} }
} }
} }
@ -154,9 +152,6 @@ impl BatchKind {
allow_index_creation, allow_index_creation,
settings_ids: vec![task_id], settings_ids: vec![task_id],
}), }),
K::DumpExport | K::Snapshot | K::TaskCancelation | K::TaskDeletion => {
unreachable!()
}
} }
} }
@ -268,7 +263,7 @@ impl BatchKind {
BatchKind::Settings { settings_ids, allow_index_creation }, BatchKind::Settings { settings_ids, allow_index_creation },
K::DocumentClear, K::DocumentClear,
) => Continue(BatchKind::ClearAndSettings { ) => Continue(BatchKind::ClearAndSettings {
settings_ids: settings_ids, settings_ids,
allow_index_creation, allow_index_creation,
other: vec![id], other: vec![id],
}), }),
@ -379,9 +374,6 @@ impl BatchKind {
import_ids, import_ids,
}) })
} }
(_, K::TaskCancelation | K::TaskDeletion | K::DumpExport | K::Snapshot) => {
unreachable!()
}
( (
BatchKind::IndexCreation { .. } BatchKind::IndexCreation { .. }
| BatchKind::IndexDeletion { .. } | BatchKind::IndexDeletion { .. }

1
index-scheduler/src/batch.rs
View File

@ -1,7 +1,6 @@
use std::collections::HashSet; use std::collections::HashSet;
use std::fs::File; use std::fs::File;
use std::io::BufWriter; use std::io::BufWriter;
use std::sync::atomic::Ordering::Relaxed;
use crate::{autobatcher::BatchKind, Error, IndexScheduler, Result, TaskId}; use crate::{autobatcher::BatchKind, Error, IndexScheduler, Result, TaskId};