matrix-rust-sdk

public

Star0

Fork 0

Watch0

47 commits 4 branches 0 tags 0 releases16.6 MiB

Commit `0e8b88a00ce2`

tarball

atagen <boss@atagen.co>2026-10-27 04:45 UTC

2 files changed+7-0

event-cache: skip the history coordinator when no sync hole is recorded

`probe_sync_hole` runs every 30s for each open room, and queued a `HistoryOperation::ProbeSyncHole` behind fills and restores even when `take_sync_hole` would find nothing. A read of the state answers that without the queue.

Modified file: crates/matrix-sdk/src/event_cache/caches/room/history.rs+3 additions@@ -448,6 +448,9 @@ impl RoomEventCache {
 
     #[doc = "Looks once behind the newest previous-batch token a non-limited sync handed out. Answers None when there was none, else how many unknown events it inserted."]
     pub async fn probe_sync_hole(&self) -> Result<Option<usize>> {
+        if !self.inner.state.read().await?.has_sync_hole() {
+            return Ok(None);
+        }
         match self.request_history(HistoryOperation::ProbeSyncHole).await? {
             HistoryResponse::Probe(outcome) => Ok(outcome),
             _ => unreachable!("coordinator response matches request"),

Modified file: crates/matrix-sdk/src/event_cache/caches/room/state.rs+4 additions@@ -462,6 +462,10 @@ impl<'a> RoomEventCacheStateLockReadGuard<'a> {
         super::history::gap_positions(&self.state.room_linked_chunk)
     }
 
+    pub(super) fn has_sync_hole(&self) -> bool {
+        self.state.sync_hole.is_some()
+    }
+
     /// Return the subscriber count.
     pub fn subscriber_count(&self) -> &Arc<AtomicUsize> {
         &self.state.subscriber_count

matrix-rust-sdk

Commit 0e8b88a00ce2

Commit `0e8b88a00ce2`