magmaus3/continuwuity
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

slightly cleanup prev_event eval loop

Browse source 
Signed-off-by: Jason Volk <jason@zemos.net>
This commit is contained in:
Jason Volk 2024-10-24 11:24:03 +00:00
parent 0e616f1d12
commit e175b7d28d
1 changed files with 21 additions and 20 deletions
Download patch file Download diff file Expand all files Collapse all files

41
src/service/rooms/event_handler/mod.rs
View file

@ -206,7 +206,7 @@ impl Service {
debug!(events = ?sorted_prev_events, "Got previous events"); debug!(events = ?sorted_prev_events, "Got previous events");
for prev_id in sorted_prev_events { for prev_id in sorted_prev_events {
self.services.server.check_running()?; self.services.server.check_running()?;
match self if let Err(e) = self
.handle_prev_pdu( .handle_prev_pdu(
origin, origin,
event_id, event_id,
@ -218,25 +218,26 @@ impl Service {
) )
.await .await
{ {
Ok(()) => continue, use hash_map::Entry;
Err(e) => {
warn!("Prev event {prev_id} failed: {e}"); let now = Instant::now();
match self warn!("Prev event {prev_id} failed: {e}");
.services
.globals match self
.bad_event_ratelimiter .services
.write() .globals
.expect("locked") .bad_event_ratelimiter
.entry((*prev_id).to_owned()) .write()
{ .expect("locked")
hash_map::Entry::Vacant(e) => { .entry(prev_id.into())
e.insert((Instant::now(), 1)); {
}, Entry::Vacant(e) => {
hash_map::Entry::Occupied(mut e) => { e.insert((now, 1));
*e.get_mut() = (Instant::now(), e.get().1.saturating_add(1)); },
}, Entry::Occupied(mut e) => {
}; *e.get_mut() = (now, e.get().1.saturating_add(1));
}, },
};
} }
} }