Compare commits

..

25 commits

Author SHA1 Message Date
Jacob Taylor
6e7a3cf6cb delete more imports to quiet cargo 2025-08-25 23:26:28 -07:00
Jacob Taylor
845a64b73d demote a bunch of logs 2025-08-25 22:12:53 -07:00
Jacob Taylor
91fed80d4f delete a bad event rate limiter (bad, do not use) 2025-08-25 21:26:09 -07:00
Jacob Taylor
423ca4e664 adjust log volume 2025-08-25 21:25:42 -07:00
Jacob Taylor
e2995df505 reduce log volume (keeps 2 infos) 2025-08-25 20:51:55 -07:00
Jacob Taylor
a0bde96494 move more backfill log to info, clean up imports 2025-08-25 20:21:55 -07:00
Jacob Taylor
0e6b7f6d5f log which room is being backfilled 2025-08-25 20:21:55 -07:00
Jacob Taylor
f8b86e4598 fix warn by removing unused debug imports 2025-08-25 20:21:55 -07:00
Jacob Taylor
c4f6d1ed09 exponential backoff is now just bees. did you want bees? no? well you have them now. congrats 2025-08-25 20:21:55 -07:00
Jacob Taylor
d5039bd72f fix too many infos 2025-08-25 20:21:55 -07:00
Jacob Taylor
76b9b88ece more funny settings (part 3 of 12) 2025-08-25 20:21:55 -07:00
Jacob Taylor
4308db5e30 sender_workers scaling. this time, with feeling! 2025-08-25 20:21:55 -07:00
Jacob Taylor
0f78f77991 vehicle loan documentation now available at window 7 2025-08-25 20:21:55 -07:00
Jacob Taylor
c628f31ad2 lock the getter instead ??? c/o M 2025-08-25 20:21:55 -07:00
Jacob Taylor
10dd534def make fetching key room events less smart 2025-08-25 20:21:55 -07:00
Jacob Taylor
ed6426ea95 change rocksdb stats level to 3
scale rocksdb background jobs and subcompactions

change rocksdb default error level to info from error

delete unused num_threads function

fix warns from cargo
2025-08-25 20:21:55 -07:00
nexy7574
307a0bd627 log which room struggled to get mainline depth 2025-08-25 20:21:55 -07:00
nexy7574
528f63dfbc more logs 2025-08-25 20:21:55 -07:00
nexy7574
38c26181f8 Fix room ID check 2025-08-25 20:21:55 -07:00
nexy7574
31bc7457d6 Kick up a fuss when m.room.create is unfindable 2025-08-25 20:21:55 -07:00
nexy7574
f857440a56 Note about ruma#2064 in TODO 2025-08-25 20:21:55 -07:00
nexy7574
43ce4625b8 fix an auth rule not applying correctly 2025-08-25 20:21:55 -07:00
Jacob Taylor
0eb9db8e71 upgrade some settings to enable 5g in continuwuity
enable converged 6g at the edge in continuwuity

better stateinfo_cache_capacity default

better roomid_spacehierarchy_cache_capacity

make sender workers default better and clamp value to core count

update sender workers documentation

add more parallelism_scaled and make them public

update 1 document
2025-08-25 20:21:55 -07:00
Jacob Taylor
d15eba2920 bump the number of allowed immutable memtables by 1, to allow for greater flood protection
this should probably not be applied if you have rocksdb_atomic_flush = false (the default)
2025-08-25 20:21:55 -07:00
Jacob Taylor
35e9220284 probably incorrectly delete support for non-standardized matrix srv record 2025-08-25 20:21:55 -07:00
2 changed files with 18 additions and 21 deletions

View file

@ -306,28 +306,25 @@ impl super::Service {
#[tracing::instrument(name = "srv", level = "debug", skip(self))]
async fn query_srv_record(&self, hostname: &'_ str) -> Result<Option<FedDest>> {
let hostnames =
[format!("_matrix-fed._tcp.{hostname}."), format!("_matrix._tcp.{hostname}.")];
self.services.server.check_running()?;
for hostname in hostnames {
self.services.server.check_running()?;
debug!("querying SRV for {hostname:?}");
debug!("querying SRV for {hostname:?}");
let hostname = hostname.trim_end_matches('.');
match self.resolver.resolver.srv_lookup(hostname).await {
| Err(e) => Self::handle_resolve_error(&e, hostname)?,
| Ok(result) => {
return Ok(result.iter().next().map(|result| {
FedDest::Named(
result.target().to_string().trim_end_matches('.').to_owned(),
format!(":{}", result.port())
.as_str()
.try_into()
.unwrap_or_else(|_| FedDest::default_port()),
)
}));
},
}
let hostname_suffix = format!("_matrix-fed._tcp.{hostname}.");
let hostname = hostname_suffix.trim_end_matches('.');
match self.resolver.resolver.srv_lookup(hostname).await {
| Err(e) => Self::handle_resolve_error(&e, hostname)?,
| Ok(result) => {
return Ok(result.iter().next().map(|result| {
FedDest::Named(
result.target().to_string().trim_end_matches('.').to_owned(),
format!(":{}", result.port())
.as_str()
.try_into()
.unwrap_or_else(|_| FedDest::default_port()),
)
}));
},
}
Ok(None)

View file

@ -123,7 +123,7 @@ where
// The original create event must be in the auth events
if !auth_events.contains_key(&(StateEventType::RoomCreate, String::new().into())) {
return Err!(Request(InvalidParam("Incoming event refers to wrong create event. event_id={event_id}")));
return Err!(Request(InvalidParam("Incoming event refers to wrong create event.")));
}
let state_fetch = |ty: &StateEventType, sk: &str| {