diff options
| author | Erik Johnston <erik@matrix.org> | 2016-09-15 11:47:23 +0100 |
|---|---|---|
| committer | Erik Johnston <erik@matrix.org> | 2016-09-15 11:47:23 +0100 |
| commit | 211786ecd629588f2481c94217a4a388b090c993 (patch) | |
| tree | 0ba7a3190107ffc2c87d10546ed111ad9f68d7f2 /synapse/replication/slave/storage/events.py | |
| parent | Base public room list off of public_rooms stream (diff) | |
| download | synapse-211786ecd629588f2481c94217a4a388b090c993.tar.xz | |
Stream public room changes down replication
Diffstat (limited to 'synapse/replication/slave/storage/events.py')
| -rw-r--r-- | synapse/replication/slave/storage/events.py | 8 |
1 files changed, 8 insertions, 0 deletions
diff --git a/synapse/replication/slave/storage/events.py b/synapse/replication/slave/storage/events.py index 15c52774a2..f8965c73a0 100644 --- a/synapse/replication/slave/storage/events.py +++ b/synapse/replication/slave/storage/events.py @@ -61,6 +61,8 @@ class SlavedEventStore(BaseSlavedStore): "MembershipStreamChangeCache", events_max, ) + self.stream_ordering_month_ago = 0 + # Cached functions can't be accessed through a class instance so we need # to reach inside the __dict__ to extract them. get_rooms_for_user = RoomMemberStore.__dict__["get_rooms_for_user"] @@ -168,6 +170,12 @@ class SlavedEventStore(BaseSlavedStore): get_auth_chain_ids = DataStore.get_auth_chain_ids.__func__ _get_auth_chain_ids_txn = DataStore._get_auth_chain_ids_txn.__func__ + get_room_max_stream_ordering = DataStore.get_room_max_stream_ordering.__func__ + + get_forward_extremeties_for_room = ( + DataStore.get_forward_extremeties_for_room.__func__ + ) + def stream_positions(self): result = super(SlavedEventStore, self).stream_positions() result["events"] = self._stream_id_gen.get_current_token() |