TudbuT/conduit
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

clear ratelimits when clearing cache too

Browse source 
Signed-off-by: strawberry <strawberry@puppygock.gay>
This commit is contained in:
strawberry 2024-04-15 18:40:01 -04:00 • committed by June
parent 6d47c20efa
commit c76445e9c1
1 changed files with 22 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

23
src/service/mod.rs
View file

@ -211,6 +211,10 @@ impl Services<'_> {
.len();
let resolver_overrides_cache = self.globals.resolver.overrides.read().unwrap().len();
let resolver_destinations_cache = self.globals.resolver.destinations.read().await.len();
let servername_ratelimiter = self.globals.servername_ratelimiter.read().await.len();
let bad_event_ratelimiter = self.globals.bad_event_ratelimiter.read().await.len();
let bad_query_ratelimiter = self.globals.bad_query_ratelimiter.read().await.len();
let bad_signature_ratelimiter = self.globals.bad_signature_ratelimiter.read().await.len();
format!(
"\
@ -221,7 +225,12 @@ stateinfo_cache: {stateinfo_cache}
lasttimelinecount_cache: {lasttimelinecount_cache}
roomid_spacehierarchy_cache: {roomid_spacehierarchy_cache}
resolver_overrides_cache: {resolver_overrides_cache}
resolver_destinations_cache: {resolver_destinations_cache}"
resolver_destinations_cache: {resolver_destinations_cache}
servername_ratelimiter: {servername_ratelimiter}
bad_event_ratelimiter: {bad_event_ratelimiter}
bad_query_ratelimiter: {bad_query_ratelimiter}
bad_signature_ratelimiter: {bad_signature_ratelimiter}
"
)
}
@ -281,5 +290,17 @@ resolver_destinations_cache: {resolver_destinations_cache}"
if amount > 7 {
self.globals.resolver.resolver.clear_cache();
}
if amount > 8 {
self.globals.servername_ratelimiter.write().await.clear();
}
if amount > 9 {
self.globals.bad_event_ratelimiter.write().await.clear();
}
if amount > 10 {
self.globals.bad_query_ratelimiter.write().await.clear();
}
if amount > 11 {
self.globals.bad_signature_ratelimiter.write().await.clear();
}
}
}