diff options
| author | Mark Haines <mark.haines@matrix.org> | 2016-04-06 16:17:15 +0100 |
|---|---|---|
| committer | Mark Haines <mark.haines@matrix.org> | 2016-04-06 16:20:13 +0100 |
| commit | 6bfec56796132520ad864ad00f8dd6773512f9f4 (patch) | |
| tree | b5f0d0df4d80e5f826a3577f0bb8cda3b3df5bd8 /synapse/replication/slave | |
| parent | Merge pull request #697 from matrix-org/markjh/slaveI (diff) | |
| download | synapse-6bfec56796132520ad864ad00f8dd6773512f9f4.tar.xz | |
Test that room membership is replicated
Diffstat (limited to 'synapse/replication/slave')
| -rw-r--r-- | synapse/replication/slave/storage/events.py | 7 |
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() |