diff options
author | Sean Quah <8349537+squahtx@users.noreply.github.com> | 2022-09-23 17:55:15 +0100 |
---|---|---|
committer | GitHub <noreply@github.com> | 2022-09-23 17:55:15 +0100 |
commit | f49f73c0da5502792c65d3de1ffd352ceb6af562 (patch) | |
tree | e8d5b3977fbedc192df6b8b4a3a1ec26aa0eff22 /synapse/storage/controllers | |
parent | Fix access token leak to logs from proxyagent (#13855) (diff) | |
download | synapse-f49f73c0da5502792c65d3de1ffd352ceb6af562.tar.xz |
Faster room joins: Avoid blocking `/keys/changes` (#13888)
Part of the work for #12993. Once #12993 is fully resolved, we expect `/keys/changes` to behave sensibly when joined to a room with partial state. Signed-off-by: Sean Quah <seanq@matrix.org>
Diffstat (limited to 'synapse/storage/controllers')
-rw-r--r-- | synapse/storage/controllers/state.py | 7 |
1 files changed, 6 insertions, 1 deletions
diff --git a/synapse/storage/controllers/state.py b/synapse/storage/controllers/state.py index b1aa17047c..bb60130afe 100644 --- a/synapse/storage/controllers/state.py +++ b/synapse/storage/controllers/state.py @@ -407,6 +407,7 @@ class StateStorageController: self, room_id: str, state_filter: Optional[StateFilter] = None, + await_full_state: bool = True, on_invalidate: Optional[Callable[[], None]] = None, ) -> StateMap[str]: """Get the current state event ids for a room based on the @@ -419,13 +420,17 @@ class StateStorageController: room_id: The room to get the state IDs of. state_filter: The state filter used to fetch state from the database. + await_full_state: if true, will block if we do not yet have complete + state for the room. on_invalidate: Callback for when the `get_current_state_ids` cache for the room gets invalidated. Returns: The current state of the room. """ - if not state_filter or state_filter.must_await_full_state(self._is_mine_id): + if await_full_state and ( + not state_filter or state_filter.must_await_full_state(self._is_mine_id) + ): await self._partial_state_room_tracker.await_full_state(room_id) if state_filter and not state_filter.is_full(): |