forked from janek/mostr
fix: flush after backtrack
This commit is contained in:
parent
db4f9ee8cb
commit
b5b57b7ac9
12
src/main.rs
12
src/main.rs
|
@ -35,15 +35,13 @@ struct EventSender {
|
||||||
impl EventSender {
|
impl EventSender {
|
||||||
fn submit(&self, event_builder: EventBuilder) -> Result<Event> {
|
fn submit(&self, event_builder: EventBuilder) -> Result<Event> {
|
||||||
{
|
{
|
||||||
// Flush if oldest event older than a minute
|
// Always flush if oldest event older than a minute or newer than now
|
||||||
let borrow = self.queue.borrow();
|
let borrow = self.queue.borrow();
|
||||||
if let Some(event) = borrow.first() {
|
let min = Timestamp::now().sub(60u64);
|
||||||
let old = event.created_at < Timestamp::now().sub(60u64);
|
if borrow.iter().any(|e| e.created_at < min || e.created_at > Timestamp::now()) {
|
||||||
drop(borrow);
|
drop(borrow);
|
||||||
if old {
|
debug!("Flushing event queue because it is older than a minute");
|
||||||
debug!("Flushing event queue because it is older than a minute");
|
self.force_flush();
|
||||||
self.force_flush();
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
let mut queue = self.queue.borrow_mut();
|
let mut queue = self.queue.borrow_mut();
|
||||||
|
|
Loading…
Reference in New Issue