summary refs log tree commit diff
path: root/synapse/replication/slave
diff options
context:
space:
mode:
authorErik Johnston <erik@matrix.org>2016-12-12 14:41:51 +0000
committerErik Johnston <erik@matrix.org>2016-12-12 14:41:51 +0000
commit09cbcb78d3f474ada72d604a24a44c91f2fdb6fe (patch)
tree4ec07e03d751f3c2007db333abde79f13683639a /synapse/replication/slave
parentNotify replication. Use correct network_id (diff)
downloadsynapse-09cbcb78d3f474ada72d604a24a44c91f2fdb6fe.tar.xz
Add cache to get_public_room_ids_at_stream_id
Diffstat (limited to 'synapse/replication/slave')
-rw-r--r--synapse/replication/slave/storage/room.py3
1 files changed, 2 insertions, 1 deletions
diff --git a/synapse/replication/slave/storage/room.py b/synapse/replication/slave/storage/room.py
index 23c613863f..6df9a25ef3 100644
--- a/synapse/replication/slave/storage/room.py
+++ b/synapse/replication/slave/storage/room.py
@@ -15,6 +15,7 @@
 
 from ._base import BaseSlavedStore
 from synapse.storage import DataStore
+from synapse.storage.room import RoomStore
 from ._slaved_id_tracker import SlavedIdTracker
 
 
@@ -30,7 +31,7 @@ class RoomStore(BaseSlavedStore):
         DataStore.get_current_public_room_stream_id.__func__
     )
     get_public_room_ids_at_stream_id = (
-        DataStore.get_public_room_ids_at_stream_id.__func__
+        RoomStore.__dict__["get_public_room_ids_at_stream_id"]
     )
     get_public_room_ids_at_stream_id_txn = (
         DataStore.get_public_room_ids_at_stream_id_txn.__func__