diff options
| author | Erik Johnston <erik@matrix.org> | 2016-11-21 11:28:37 +0000 |
|---|---|---|
| committer | Erik Johnston <erik@matrix.org> | 2016-11-21 11:33:08 +0000 |
| commit | 7c9cdb22453d1a442e5c280149aeeff4d46da215 (patch) | |
| tree | 1434dca32f57320810b5e70314db521f5cc7a338 /synapse/replication/slave | |
| parent | Handle sending events and device messages over federation (diff) | |
| download | synapse-7c9cdb22453d1a442e5c280149aeeff4d46da215.tar.xz | |
Store federation stream positions in the database
Diffstat (limited to 'synapse/replication/slave')
| -rw-r--r-- | synapse/replication/slave/storage/events.py | 3 |
1 files changed, 3 insertions, 0 deletions
diff --git a/synapse/replication/slave/storage/events.py b/synapse/replication/slave/storage/events.py index ef8713b55d..64f18bbb3e 100644 --- a/synapse/replication/slave/storage/events.py +++ b/synapse/replication/slave/storage/events.py @@ -187,6 +187,9 @@ class SlavedEventStore(BaseSlavedStore): get_all_new_events_stream = DataStore.get_all_new_events_stream.__func__ + get_federation_out_pos = DataStore.get_federation_out_pos.__func__ + update_federation_out_pos = DataStore.update_federation_out_pos.__func__ + def stream_positions(self): result = super(SlavedEventStore, self).stream_positions() result["events"] = self._stream_id_gen.get_current_token() |