matrix-rust-sdk

public

Star0

Fork 0

Watch0

29 commits 4 branches 0 tags 0 releases16.6 MiB

Commit `20345c614cc1`

tarball

atagen <boss@atagen.co>2026-10-25 10:49 UTC

1 file changed+9-0

event-cache: restart an event-focused cache once per generation

Two clears in quick succession spawned two restarts, and the second ran start_from on a chunk the first had already refilled for the same generation, so subscribers saw every focused event twice. A restart now synchronises the generation first and stops when the chunk is already filled.

Modified file: crates/matrix-sdk/src/event_cache/caches/event_focused/mod.rs+9 additions@@ -631,6 +631,15 @@ impl EventFocusedCache {
         let cache = self.clone();
         matrix_sdk_common::executor::spawn(async move {
             let mut inner = cache.inner.write().await;
+            {
+                let invalidation_lock = inner.invalidation_lock.clone();
+                let _guard = invalidation_lock.lock().unwrap();
+                inner.synchronize_generation();
+            }
+            // Another restart already refilled this generation after back-to-back clears.
+            if inner.chunk.events().next().is_some() {
+                return;
+            }
             let Some((num_context_events, thread_mode)) = inner.context else {
                 return;
             };

matrix-rust-sdk

Commit 20345c614cc1

Commit `20345c614cc1`