mirror of
https://forgejo.ellis.link/continuwuation/continuwuity.git
synced 2026-11-14 12:46:49 +00:00
fix: Mark PDUs as referenced during gapfill immediately
This commit is contained in:
1 file changed
+4
-3
@@ -1,4 +1,4 @@
|
|||||||
use std::{collections::HashMap, time::Instant};
|
use std::{collections::HashMap, iter::once, time::Instant};
|
||||||
|
|
||||||
use conduwuit::{
|
use conduwuit::{
|
||||||
Err, Event, PduEvent, debug, debug_info, debug_warn, trace,
|
Err, Event, PduEvent, debug, debug_info, debug_warn, trace,
|
||||||
@@ -107,6 +107,9 @@ impl super::Service {
|
|||||||
);
|
);
|
||||||
let obj = mapped.get(event_id).cloned().unwrap();
|
let obj = mapped.get(event_id).cloned().unwrap();
|
||||||
let persist_start = Instant::now();
|
let persist_start = Instant::now();
|
||||||
|
self.services
|
||||||
|
.pdu_metadata
|
||||||
|
.mark_as_referenced(room_id, once(event_id.to_owned().as_ref()));
|
||||||
match self
|
match self
|
||||||
.handle_outlier_pdu(origin, create_event, event_id, room_id, obj)
|
.handle_outlier_pdu(origin, create_event, event_id, room_id, obj)
|
||||||
.await
|
.await
|
||||||
@@ -148,8 +151,6 @@ impl super::Service {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
// NOTE because i keep forgetting: the caller persists incoming_pdu.
|
|
||||||
// we only care about its prev events
|
|
||||||
trace!(
|
trace!(
|
||||||
total_elapsed=?start.elapsed(),
|
total_elapsed=?start.elapsed(),
|
||||||
persist_elapsed=?job_start.elapsed(),
|
persist_elapsed=?job_start.elapsed(),
|
||||||
|
|||||||
Reference in new issue
Block a user