From fb54e869e9bf7f372ef6f48e4731c7bae8703bee Mon Sep 17 00:00:00 2001
From: Benjamin Bouvier <benjamin@bouvier.cc>
Date: Tue, 7 Jan 2025 17:32:05 +0100
Subject: [PATCH] chore(event cache): add more logs when the event cache tasks
 are shutting down

---
 crates/matrix-sdk/src/event_cache/mod.rs | 9 ++++++---
 1 file changed, 6 insertions(+), 3 deletions(-)

diff --git a/crates/matrix-sdk/src/event_cache/mod.rs b/crates/matrix-sdk/src/event_cache/mod.rs
index 6fbbbb7deaf..d41c54d88bd 100644
--- a/crates/matrix-sdk/src/event_cache/mod.rs
+++ b/crates/matrix-sdk/src/event_cache/mod.rs
@@ -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;
                 }
             }