diff options
| author | Erik Johnston <erik@matrix.org> | 2019-12-04 15:45:42 +0000 |
|---|---|---|
| committer | Erik Johnston <erik@matrix.org> | 2019-12-04 15:45:42 +0000 |
| commit | a7f20500ff39399634d4623e284fb2f9892776ae (patch) | |
| tree | 8052882125ba484783bea3d5d3d9e76c7afbc0d3 /synapse/storage/data_stores | |
| parent | Move get_user_count_txn out of base store (diff) | |
| download | synapse-a7f20500ff39399634d4623e284fb2f9892776ae.tar.xz | |
_CURRENT_STATE_CACHE_NAME is public
Diffstat (limited to 'synapse/storage/data_stores')
| -rw-r--r-- | synapse/storage/data_stores/main/cache.py | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/synapse/storage/data_stores/main/cache.py b/synapse/storage/data_stores/main/cache.py index 6efcc5f3b0..258c08722a 100644 --- a/synapse/storage/data_stores/main/cache.py +++ b/synapse/storage/data_stores/main/cache.py @@ -28,7 +28,7 @@ logger = logging.getLogger(__name__) # This is a special cache name we use to batch multiple invalidations of caches # based on the current state when notifying workers over replication. -_CURRENT_STATE_CACHE_NAME = "cs_cache_fake" +CURRENT_STATE_CACHE_NAME = "cs_cache_fake" class CacheInvalidationStore(SQLBaseStore): @@ -65,12 +65,12 @@ class CacheInvalidationStore(SQLBaseStore): for chunk in batch_iter(members_changed, 50): keys = itertools.chain([room_id], chunk) self._send_invalidation_to_replication( - txn, _CURRENT_STATE_CACHE_NAME, keys + txn, CURRENT_STATE_CACHE_NAME, keys ) else: # if no members changed, we still need to invalidate the other caches. self._send_invalidation_to_replication( - txn, _CURRENT_STATE_CACHE_NAME, [room_id] + txn, CURRENT_STATE_CACHE_NAME, [room_id] ) def _send_invalidation_to_replication(self, txn, cache_name, keys): |