summary refs log tree commit diff
path: root/synapse/storage/data_stores
diff options
context:
space:
mode:
authorErik Johnston <erik@matrix.org>2019-12-04 15:45:42 +0000
committerErik Johnston <erik@matrix.org>2019-12-04 15:45:42 +0000
commita7f20500ff39399634d4623e284fb2f9892776ae (patch)
tree8052882125ba484783bea3d5d3d9e76c7afbc0d3 /synapse/storage/data_stores
parentMove get_user_count_txn out of base store (diff)
downloadsynapse-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.py6
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):