mirror/matrix-rust-sdk
1
0
Fork 0
mirror of https://github.com/matrix-org/matrix-rust-sdk.git synced 2026-05-12 18:21:21 -04:00
Code Issues Packages Projects Releases Wiki Activity

chore(event cache): add more logs when the event cache tasks are shutting down

Browse Source
This commit is contained in:
Benjamin Bouvier
2025-01-07 17:32:05 +01:00
parent 9e97ed3134
commit fb54e869e9
1 changed files with 6 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
crates/matrix-sdk/src/event_cache/mod.rs
View File

@@ -248,11 +248,12 @@ impl EventCache {
async move {
while ignore_user_list_stream.next().await.is_some() {
info!("received an ignore user list change");
info!("Received an ignore user list change");
if let Err(err) = inner.clear_all_rooms().await {
error!("error when clearing room storage: {err}");
error!("when clearing room storage after ignore user list change: {err}");
}
}
info!("Ignore user list stream has closed");
}
.instrument(span)
.await;
@@ -271,6 +272,7 @@ impl EventCache {
match err {
EventCacheError::ClientDropped => {
// The client has dropped, exit the listen task.
info!("Closing the event cache global listen task because client dropped");
break;
}
err => {
@@ -286,12 +288,13 @@ impl EventCache {
// TODO: implement Smart Matching™,
warn!(num_skipped, "Lagged behind room updates, clearing all rooms");
if let Err(err) = inner.clear_all_rooms().await {
error!("error when clearing storage: {err}");
error!("when clearing storage after lag in listen_task: {err}");
}
}
Err(RecvError::Closed) => {
// The sender has shut down, exit.
info!("Closing the event cache global listen task because receiver closed");
break;
}
}