diff options
| author | Erik Johnston <erikj@jki.re> | 2019-02-19 13:14:30 +0000 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2019-02-19 13:14:30 +0000 |
| commit | c003450057057106d4032a152eff931f4fc34f1c (patch) | |
| tree | 57fb93ef20a0c5c02c1a13715e96514264daa5e7 /synapse/storage/events.py | |
| parent | Merge pull request #4676 from matrix-org/rav/pg95 (diff) | |
| parent | Docs (diff) | |
| download | synapse-c003450057057106d4032a152eff931f4fc34f1c.tar.xz | |
Merge pull request #4671 from matrix-org/erikj/state_cache_invalidation
Batch cache invalidation over replication
Diffstat (limited to 'synapse/storage/events.py')
| -rw-r--r-- | synapse/storage/events.py | 25 |
1 files changed, 1 insertions, 24 deletions
diff --git a/synapse/storage/events.py b/synapse/storage/events.py index 81b250480d..06db9e56e6 100644 --- a/synapse/storage/events.py +++ b/synapse/storage/events.py @@ -979,30 +979,7 @@ class EventsStore(StateGroupWorkerStore, EventFederationStore, EventsWorkerStore if ev_type == EventTypes.Member ) - for member in members_changed: - self._invalidate_cache_and_stream( - txn, self.get_rooms_for_user_with_stream_ordering, (member,) - ) - - for host in set(get_domain_from_id(u) for u in members_changed): - self._invalidate_cache_and_stream( - txn, self.is_host_joined, (room_id, host) - ) - self._invalidate_cache_and_stream( - txn, self.was_host_joined, (room_id, host) - ) - - self._invalidate_cache_and_stream( - txn, self.get_users_in_room, (room_id,) - ) - - self._invalidate_cache_and_stream( - txn, self.get_room_summary, (room_id,) - ) - - self._invalidate_cache_and_stream( - txn, self.get_current_state_ids, (room_id,) - ) + self._invalidate_state_caches_and_stream(txn, room_id, members_changed) def _update_forward_extremities_txn(self, txn, new_forward_extremities, max_stream_order): |