magmaus3/continuwuity
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

improve tracing/logging for state_compressor

Browse source 
Signed-off-by: Jason Volk <jason@zemos.net>
This commit is contained in:
Jason Volk 2024-11-15 03:41:08 +00:00
parent 5f625216aa
commit 9f7a4a012b
1 changed files with 10 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

12
src/service/rooms/state_compressor/mod.rs
View file

@ -7,7 +7,7 @@ use std::{
use arrayvec::ArrayVec; use arrayvec::ArrayVec;
use conduit::{ use conduit::{
at, checked, err, expected, utils, at, checked, debug, err, expected, utils,
utils::{bytes, math::usize_from_f64}, utils::{bytes, math::usize_from_f64},
Result, Result,
}; };
@ -157,6 +157,13 @@ impl Service {
}] }]
}; };
debug!(
?parent,
?shortstatehash,
vec_len = %response.len(),
"cache update"
);
self.stateinfo_cache self.stateinfo_cache
.lock() .lock()
.expect("locked") .expect("locked")
@ -218,7 +225,6 @@ impl Service {
/// for this layer /// for this layer
/// * `parent_states` - A stack with info on shortstatehash, full state, /// * `parent_states` - A stack with info on shortstatehash, full state,
/// added diff and removed diff for each parent layer /// added diff and removed diff for each parent layer
#[tracing::instrument(skip_all, level = "debug")]
pub fn save_state_from_diff( pub fn save_state_from_diff(
&self, shortstatehash: ShortStateHash, statediffnew: Arc<HashSet<CompressedStateEvent>>, &self, shortstatehash: ShortStateHash, statediffnew: Arc<HashSet<CompressedStateEvent>>,
statediffremoved: Arc<HashSet<CompressedStateEvent>>, diff_to_sibling: usize, statediffremoved: Arc<HashSet<CompressedStateEvent>>, diff_to_sibling: usize,
@ -335,6 +341,7 @@ impl Service {
/// Returns the new shortstatehash, and the state diff from the previous /// Returns the new shortstatehash, and the state diff from the previous
/// room state /// room state
#[tracing::instrument(skip(self, new_state_ids_compressed), level = "debug")]
pub async fn save_state( pub async fn save_state(
&self, room_id: &RoomId, new_state_ids_compressed: Arc<HashSet<CompressedStateEvent>>, &self, room_id: &RoomId, new_state_ids_compressed: Arc<HashSet<CompressedStateEvent>>,
) -> Result<HashSetCompressStateEvent> { ) -> Result<HashSetCompressStateEvent> {
@ -405,6 +412,7 @@ impl Service {
}) })
} }
#[tracing::instrument(skip(self), level = "debug", name = "get")]
async fn get_statediff(&self, shortstatehash: ShortStateHash) -> Result<StateDiff> { async fn get_statediff(&self, shortstatehash: ShortStateHash) -> Result<StateDiff> {
const BUFSIZE: usize = size_of::<ShortStateHash>(); const BUFSIZE: usize = size_of::<ShortStateHash>();
const STRIDE: usize = size_of::<ShortStateHash>(); const STRIDE: usize = size_of::<ShortStateHash>();