mirror of
https://forgejo.ellis.link/continuwuation/continuwuity.git
synced 2025-09-11 23:53:01 +02:00
Compare commits
8 commits
60b8c9f5f2
...
2106e4e9f4
Author | SHA1 | Date | |
---|---|---|---|
|
2106e4e9f4 | ||
|
8c8c023120 | ||
|
5f2a24d7b2 | ||
|
1934711276 | ||
|
1807643371 | ||
|
6d6593c5eb | ||
|
63ee2dacea | ||
|
b8ead96d3e |
1 changed files with 5 additions and 25 deletions
|
@ -3,7 +3,11 @@ use std::{
|
||||||
time::Instant,
|
time::Instant,
|
||||||
};
|
};
|
||||||
|
|
||||||
use conduwuit::{Event, PduEvent, debug, debug_error, implement, matrix::event::gen_event_id_canonical_json, trace, utils::continue_exponential_backoff_secs, warn, debug_warn};
|
use conduwuit::{
|
||||||
|
Event, PduEvent, debug, debug_error, implement,
|
||||||
|
matrix::event::gen_event_id_canonical_json, trace, utils::continue_exponential_backoff_secs,
|
||||||
|
warn,
|
||||||
|
};
|
||||||
use ruma::{
|
use ruma::{
|
||||||
CanonicalJsonValue, EventId, OwnedEventId, RoomId, ServerName,
|
CanonicalJsonValue, EventId, OwnedEventId, RoomId, ServerName,
|
||||||
api::federation::event::get_event,
|
api::federation::event::get_event,
|
||||||
|
@ -66,30 +70,6 @@ where
|
||||||
|
|
||||||
let mut events_all = HashSet::with_capacity(todo_auth_events.len());
|
let mut events_all = HashSet::with_capacity(todo_auth_events.len());
|
||||||
while let Some(next_id) = todo_auth_events.pop_front() {
|
while let Some(next_id) = todo_auth_events.pop_front() {
|
||||||
if let Some((time, tries)) = self
|
|
||||||
.services
|
|
||||||
.globals
|
|
||||||
.bad_event_ratelimiter
|
|
||||||
.read()
|
|
||||||
.get(&*next_id)
|
|
||||||
{
|
|
||||||
// Exponential backoff
|
|
||||||
const MIN_DURATION: u64 = 60 * 2;
|
|
||||||
const MAX_DURATION: u64 = 60 * 60;
|
|
||||||
if continue_exponential_backoff_secs(
|
|
||||||
MIN_DURATION,
|
|
||||||
MAX_DURATION,
|
|
||||||
time.elapsed(),
|
|
||||||
*tries,
|
|
||||||
) {
|
|
||||||
debug_warn!(
|
|
||||||
tried = ?*tries,
|
|
||||||
elapsed = ?time.elapsed(),
|
|
||||||
"Backing off from {next_id}",
|
|
||||||
);
|
|
||||||
continue;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
if events_all.contains(&next_id) {
|
if events_all.contains(&next_id) {
|
||||||
continue;
|
continue;
|
||||||
|
|
Loading…
Add table
Add a link
Reference in a new issue