Matrix-Mirrors/synapse-product
1
0
Fork 0
mirror of https://git.anonymousland.org/anonymousland/synapse-product.git synced 2024-12-24 08:29:25 -05:00
Code Issues Packages Projects Releases Wiki Activity

Docs

Browse Source
This commit is contained in:
Erik Johnston 2019-02-19 11:38:40 +00:00
parent 1bb35e3a83
commit 62175a20e5
2 changed files with 8 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
docs/tcp_replication.rst
View File

@ -240,3 +240,8 @@ However, there are times when a number of caches need to be invalidated at the
same time with the same key. To reduce traffic we batch those invalidations into same time with the same key. To reduce traffic we batch those invalidations into
a single poke by defining a special cache name that workers understand to mean a single poke by defining a special cache name that workers understand to mean
to expand to invalidate the correct caches. to expand to invalidate the correct caches.
Currently the special cache names are declared in ``synapse/storage/_base.py``
and are:
1. ``cs_cache_fake`` ─ invalidates caches that depend on the current state

5
synapse/storage/_base.py
View File

@ -1201,7 +1201,7 @@ class SQLBaseStore(object):
Args: Args:
txn txn
room_id (str): Room where state changed room_id (str): Room where state changed
members_changed (Iterable[str]): The user_ids of members that have changed members_changed (iterable[str]): The user_ids of members that have changed
""" """
txn.call_after(self._invalidate_state_caches, room_id, members_changed) txn.call_after(self._invalidate_state_caches, room_id, members_changed)
@ -1216,7 +1216,8 @@ class SQLBaseStore(object):
Args: Args:
room_id (str): Room where state changed room_id (str): Room where state changed
members_changed (set[str]): The user_ids of members that have changed members_changed (iterable[str]): The user_ids of members that have
changed
""" """
for member in members_changed: for member in members_changed:
self.get_rooms_for_user_with_stream_ordering.invalidate((member,)) self.get_rooms_for_user_with_stream_ordering.invalidate((member,))