diff options
author | Erik Johnston <erik@matrix.org> | 2016-07-21 17:37:44 +0100 |
---|---|---|
committer | Erik Johnston <erik@matrix.org> | 2016-07-21 17:37:44 +0100 |
commit | aede7248ab04118b83d7787547b9cf3fd615e7ad (patch) | |
tree | d9b54d82904e12cc5554730201347c12f610314c /synapse/replication/slave/storage/events.py | |
parent | Merge pull request #943 from matrix-org/rav/get_device_api (diff) | |
download | synapse-aede7248ab04118b83d7787547b9cf3fd615e7ad.tar.xz |
Split out a FederationReader process
Diffstat (limited to 'synapse/replication/slave/storage/events.py')
-rw-r--r-- | synapse/replication/slave/storage/events.py | 5 |
1 files changed, 5 insertions, 0 deletions
diff --git a/synapse/replication/slave/storage/events.py b/synapse/replication/slave/storage/events.py index 369d839464..2ba1e6b803 100644 --- a/synapse/replication/slave/storage/events.py +++ b/synapse/replication/slave/storage/events.py @@ -142,6 +142,11 @@ class SlavedEventStore(BaseSlavedStore): _get_events_around_txn = DataStore._get_events_around_txn.__func__ _get_some_state_from_cache = DataStore._get_some_state_from_cache.__func__ + get_backfill_events = DataStore.get_backfill_events.__func__ + _get_backfill_events = DataStore._get_backfill_events.__func__ + get_missing_events = DataStore.get_missing_events.__func__ + _get_missing_events = DataStore._get_missing_events.__func__ + def stream_positions(self): result = super(SlavedEventStore, self).stream_positions() result["events"] = self._stream_id_gen.get_current_token() |