snowykami/meilisearch
1
0
Fork 0
mirror of https://github.com/meilisearch/meilisearch.git synced 2025-10-31 07:56:28 +00:00
Code Issues Packages Projects Releases Wiki Activity

rename the documents batchers

Browse Source
This commit is contained in:
Tamo
2021-10-25 17:12:14 +02:00
committed by marin postma
parent e64ba122e1
commit 6591acfdfa
1 changed files with 9 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

18
meilisearch-http/src/analytics.rs
View File

@@ -53,8 +53,8 @@ mod segment {
batcher: Mutex<AutoBatcher>,
post_search_batcher: Mutex<SearchBatcher>,
get_search_batcher: Mutex<SearchBatcher>,
documents_added_batcher: Mutex<DocumentsBatcher>,
documents_updated_batcher: Mutex<DocumentsBatcher>,
add_documents_batcher: Mutex<DocumentsBatcher>,
update_documents_batcher: Mutex<DocumentsBatcher>,
}
impl SegmentAnalytics {
@@ -127,8 +127,8 @@ mod segment {
batcher,
post_search_batcher: Mutex::new(SearchBatcher::default()),
get_search_batcher: Mutex::new(SearchBatcher::default()),
documents_added_batcher: Mutex::new(DocumentsBatcher::default()),
documents_updated_batcher: Mutex::new(DocumentsBatcher::default()),
add_documents_batcher: Mutex::new(DocumentsBatcher::default()),
update_documents_batcher: Mutex::new(DocumentsBatcher::default()),
});
let segment = Box::leak(segment);
@@ -173,14 +173,14 @@ mod segment {
.into_event(&self.user, "Document Searched POST");
println!("ANALYTICS: taking the lock on the documents batchers");
let add_documents =
std::mem::take(&mut *self.documents_added_batcher.lock().await)
std::mem::take(&mut *self.add_documents_batcher.lock().await)
.into_event(&self.user, "Documents Added");
let update_documents =
std::mem::take(&mut *self.documents_updated_batcher.lock().await)
std::mem::take(&mut *self.update_documents_batcher.lock().await)
.into_event(&self.user, "Documents Updated");
// keep the lock on the batcher just for these three operations
{
println!("ANALYTICS: taking the lock on the batcher");
println!("ANALYTICS: taking the lock on the batchers");
let mut batcher = self.batcher.lock().await;
if let Some(get_search) = get_search {
let _ = batcher.push(get_search).await;
@@ -377,7 +377,7 @@ mod segment {
request: &HttpRequest,
) {
self.batch_documents(
&self.documents_added_batcher,
&self.add_documents_batcher,
documents_query,
index_creation,
request,
@@ -391,7 +391,7 @@ mod segment {
request: &HttpRequest,
) {
self.batch_documents(
&self.documents_updated_batcher,
&self.update_documents_batcher,
documents_query,
index_creation,
request,