add event_id to log entry

scale rocksdb background jobs and subcompactions

change rocksdb default error level to info from error

delete unused num_threads function

fix warns from cargo

src/service/resolver/actual.rs

@@ -306,25 +306,28 @@ impl super::Service {
 
 	#[tracing::instrument(name = "srv", level = "debug", skip(self))]
 	async fn query_srv_record(&self, hostname: &'_ str) -> Result<Option<FedDest>> {
-		self.services.server.check_running()?;
+		let hostnames =
+			[format!("_matrix-fed._tcp.{hostname}."), format!("_matrix._tcp.{hostname}.")];
 
-		debug!("querying SRV for {hostname:?}");
+		for hostname in hostnames {
+			self.services.server.check_running()?;
 
-		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()),
-					)
-				}));
-			},
+			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()),
+						)
+					}));
+				},
+			}
 		}
 
 		Ok(None)

src/service/rooms/event_handler/handle_outlier_pdu.rs

@@ -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.")));
+		return Err!(Request(InvalidParam("Incoming event refers to wrong create event. event_id={event_id}")));
 	}
 
 	let state_fetch = |ty: &StateEventType, sk: &str| {