diff --git a/src/database/engine.rs b/src/database/engine.rs index 1fa53b01..9da20803 100644 --- a/src/database/engine.rs +++ b/src/database/engine.rs @@ -296,7 +296,7 @@ pub(crate) fn repair(db_opts: &Options, path: &PathBuf) -> Result<()> { Ok(()) } -#[tracing::instrument(skip_all, name = "rocksdb")] +#[tracing::instrument(skip_all, name = "rocksdb", level = "debug")] pub(crate) fn handle_log(level: LogLevel, msg: &str) { let msg = msg.trim(); if msg.starts_with("Options") { diff --git a/src/service/rooms/auth_chain/mod.rs b/src/service/rooms/auth_chain/mod.rs index 1d0490c2..5face0b5 100644 --- a/src/service/rooms/auth_chain/mod.rs +++ b/src/service/rooms/auth_chain/mod.rs @@ -209,20 +209,23 @@ impl Service { self.db.get_cached_eventid_authchain(key).await } - #[tracing::instrument(skip(self), level = "debug")] + #[tracing::instrument(skip_all, level = "debug")] pub fn cache_auth_chain(&self, key: Vec, auth_chain: &HashSet) { - let val = auth_chain.iter().copied().collect::>(); + let val: Arc<[ShortEventId]> = auth_chain.iter().copied().collect(); + self.db.cache_auth_chain(key, val); } - #[tracing::instrument(skip(self), level = "debug")] - pub fn cache_auth_chain_vec(&self, key: Vec, auth_chain: &Vec) { - let val = auth_chain.iter().copied().collect::>(); + #[tracing::instrument(skip_all, level = "debug")] + pub fn cache_auth_chain_vec(&self, key: Vec, auth_chain: &[ShortEventId]) { + let val: Arc<[ShortEventId]> = auth_chain.iter().copied().collect(); + self.db.cache_auth_chain(key, val); } pub fn get_cache_usage(&self) -> (usize, usize) { let cache = self.db.auth_chain_cache.lock().expect("locked"); + (cache.len(), cache.capacity()) } diff --git a/src/service/rooms/state/mod.rs b/src/service/rooms/state/mod.rs index 3227b935..8bd5f7eb 100644 --- a/src/service/rooms/state/mod.rs +++ b/src/service/rooms/state/mod.rs @@ -393,7 +393,7 @@ impl Service { } /// This fetches auth events from the current state. - #[tracing::instrument(skip(self), level = "debug")] + #[tracing::instrument(skip(self, content), level = "debug")] pub async fn get_auth_events( &self, room_id: &RoomId, kind: &TimelineEventType, sender: &UserId, state_key: Option<&str>, content: &serde_json::value::RawValue,