Correctly invalidate cache on replication

tchapgouv · Jul 29, 2022 · 46f56b4 · 46f56b4
1 parent 9f26348
commit 46f56b4
Showing 1 changed file with 6 additions and 1 deletion.
diff --git a/synapse/storage/databases/main/cache.py b/synapse/storage/databases/main/cache.py
@@ -168,8 +168,13 @@ def _process_event_stream_row(self, token: int, row: EventsStreamRow) -> None:
             self._curr_state_delta_stream_cache.entity_has_changed(data.room_id, token)
 
             if data.type == EventTypes.Member:
+                # We need to invalidate the cache for get_rooms_for_user_with_stream_ordering
+                # both with and without excluding rooms for sync results.
                 self.get_rooms_for_user_with_stream_ordering.invalidate(
-                    (data.state_key,)
+                    (data.state_key, False)
+                )
+                self.get_rooms_for_user_with_stream_ordering.invalidate(
+                    (data.state_key, True)
                 )
         else:
             raise Exception("Unknown events stream row type %s" % (row.type,))