snowykami/meilisearch
1
0
Fork 0
mirror of https://github.com/meilisearch/meilisearch.git synced 2024-11-23 02:27:40 +08:00
Code Issues Actions 9 Packages Projects Releases Wiki Activity

fix index deletion bug

Browse Source
This commit is contained in:
mpostma 2021-07-05 18:42:13 +02:00
parent 2f3a439566
commit 066085f6f5
1 changed files with 6 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
meilisearch-http/src/index_controller/update_actor/store/mod.rs
View File

@ -442,13 +442,16 @@ impl UpdateStore {
while let Some(Ok(((_, uuid, _), pending))) = pendings.next() { while let Some(Ok(((_, uuid, _), pending))) = pendings.next() {
if uuid == index_uuid { if uuid == index_uuid {
unsafe {
pendings.del_current()?;
}
let mut pending = pending.decode()?; let mut pending = pending.decode()?;
if let Some(update_uuid) = pending.content.take() { if let Some(update_uuid) = pending.content.take() {
uuids_to_remove.push(update_uuid); uuids_to_remove.push(update_uuid);
} }
// Invariant check: we can only delete the current entry when we don't hold
// references to it anymore. This must be done after we have retrieved its content.
unsafe {
pendings.del_current()?;
}
} }
} }