summary refs log tree commit diff
path: root/synapse/replication/slave
diff options
context:
space:
mode:
authorMark Haines <mark.haines@matrix.org>2016-04-06 16:17:15 +0100
committerMark Haines <mark.haines@matrix.org>2016-04-06 16:20:13 +0100
commit6bfec56796132520ad864ad00f8dd6773512f9f4 (patch)
treeb5f0d0df4d80e5f826a3577f0bb8cda3b3df5bd8 /synapse/replication/slave
parentMerge pull request #697 from matrix-org/markjh/slaveI (diff)
downloadsynapse-6bfec56796132520ad864ad00f8dd6773512f9f4.tar.xz
Test that room membership is replicated
Diffstat (limited to 'synapse/replication/slave')
-rw-r--r--synapse/replication/slave/storage/events.py7
1 files changed, 4 insertions, 3 deletions
diff --git a/synapse/replication/slave/storage/events.py b/synapse/replication/slave/storage/events.py

index 68b924e37b..680dc89536 100644 --- a/synapse/replication/slave/storage/events.py +++ b/synapse/replication/slave/storage/events.py
@@ -71,9 +71,6 @@ class SlavedEventStore(BaseSlavedStore): get_current_state = DataStore.get_current_state.__func__ get_current_state_for_key = DataStore.get_current_state_for_key.__func__ - _get_rooms_for_user_where_membership_is_txn = ( - DataStore._get_rooms_for_user_where_membership_is_txn.__func__ - ) get_rooms_for_user_where_membership_is = ( DataStore.get_rooms_for_user_where_membership_is.__func__ ) @@ -95,6 +92,10 @@ class SlavedEventStore(BaseSlavedStore): _fetch_events_txn = DataStore._fetch_events_txn.__func__ _fetch_event_rows = DataStore._fetch_event_rows.__func__ _get_event_from_row_txn = DataStore._get_event_from_row_txn.__func__ + _get_rooms_for_user_where_membership_is_txn = ( + DataStore._get_rooms_for_user_where_membership_is_txn.__func__ + ) + _get_members_rows_txn = DataStore._get_members_rows_txn.__func__ def stream_positions(self): result = super(SlavedEventStore, self).stream_positions()