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

fix the timing issue

Browse Source
This commit is contained in:
Tamo 2021-10-28 16:47:56 +02:00 committed by marin postma
parent 7934e3956b
commit ba69ad672a
No known key found for this signature in database
GPG Key ID: 6088B7721C3E39F9
1 changed files with 2 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
meilisearch-http/src/analytics/segment_analytics.rs
View File

@ -214,13 +214,12 @@ impl Segment {
} }
async fn run(mut self, meilisearch: MeiliSearch) { async fn run(mut self, meilisearch: MeiliSearch) {
println!("CALLED");
const INTERVAL: Duration = Duration::from_secs(60 * 60); // one hour const INTERVAL: Duration = Duration::from_secs(60 * 60); // one hour
let mut interval = tokio::time::interval(INTERVAL);
loop { loop {
let mut interval = tokio::time::interval(INTERVAL);
select! { select! {
_ = interval.tick() => { _ = interval.tick() => {
println!("TRIGGERED");
self.tick(meilisearch.clone()).await; self.tick(meilisearch.clone()).await;
}, },
msg = self.inbox.recv() => { msg = self.inbox.recv() => {
@ -238,7 +237,6 @@ impl Segment {
} }
async fn tick(&mut self, meilisearch: MeiliSearch) { async fn tick(&mut self, meilisearch: MeiliSearch) {
println!("SENDING A TICK");
if let Ok(stats) = meilisearch.get_all_stats().await { if let Ok(stats) = meilisearch.get_all_stats().await {
let _ = self let _ = self
.batcher .batcher