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 8 Packages Projects Releases Wiki Activity

Fix document count

Browse Source
This commit is contained in:
Louis Dureuil 2023-10-31 10:57:08 +01:00
parent 94206b0055
commit da0503ef80
No known key found for this signature in database
1 changed files with 3 additions and 14 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

17
milli/src/update/index_documents/mod.rs
View File

@ -371,12 +371,11 @@ where
let _ = lmdb_writer_sx.send(Err(e)); let _ = lmdb_writer_sx.send(Err(e));
} }
// needs to be droped to avoid channel waiting lock. // needs to be dropped to avoid channel waiting lock.
drop(lmdb_writer_sx) drop(lmdb_writer_sx)
}); });
let index_documents_ids = self.index.documents_ids(self.wtxn)?; let index_is_empty = self.index.number_of_documents(self.wtxn)? == 0;
let index_is_empty = index_documents_ids.is_empty();
let mut final_documents_ids = RoaringBitmap::new(); let mut final_documents_ids = RoaringBitmap::new();
let mut databases_seen = 0; let mut databases_seen = 0;
@ -422,16 +421,6 @@ where
// We write the primary key field id into the main database // We write the primary key field id into the main database
self.index.put_primary_key(self.wtxn, &primary_key)?; self.index.put_primary_key(self.wtxn, &primary_key)?;
// We write the external documents ids into the main database.
//let mut external_documents_ids = self.index.external_documents_ids(self.wtxn)?;
//external_documents_ids.insert_ids(&new_external_documents_ids)?;
//let external_documents_ids = external_documents_ids.into_static();
//self.index.put_external_documents_ids(self.wtxn, &external_documents_ids)?;
// FIXME: remove `new_documents_ids` entirely and `replaced_documents_ids`
let all_documents_ids = index_documents_ids | new_documents_ids;
//self.index.put_documents_ids(self.wtxn, &all_documents_ids)?;
// TODO: reactivate prefix DB with diff-indexing // TODO: reactivate prefix DB with diff-indexing
// self.execute_prefix_databases( // self.execute_prefix_databases(
// word_docids, // word_docids,
@ -441,7 +430,7 @@ where
// word_fid_docids, // word_fid_docids,
// )?; // )?;
Ok(all_documents_ids.len()) self.index.number_of_documents(self.wtxn)
} }
#[logging_timer::time("IndexDocuments::{}")] #[logging_timer::time("IndexDocuments::{}")]