diff options
| author | Erik Johnston <erik@matrix.org> | 2018-07-24 16:46:30 +0100 |
|---|---|---|
| committer | Erik Johnston <erik@matrix.org> | 2018-07-24 16:49:17 +0100 |
| commit | 8b8c4f34a336376610bf353f6aa5d71c5ef69980 (patch) | |
| tree | d05bc1e6a3df5adda77e01feed03c37f90a7fcad /synapse/app | |
| parent | Pull out did_forget to worker store (diff) | |
| download | synapse-8b8c4f34a336376610bf353f6aa5d71c5ef69980.tar.xz | |
Replace usage of get_current_toke with StreamToken.START
This allows us to handle /context/ requests on the client_reader worker without having to pull in all the various stream handlers (e.g. precence, typing, pushers etc). The only thing the token gets used for is pagination, and that ignores everything but the room portion of the token.
Diffstat (limited to 'synapse/app')
| -rw-r--r-- | synapse/app/client_reader.py | 2 |
1 files changed, 2 insertions, 0 deletions
diff --git a/synapse/app/client_reader.py b/synapse/app/client_reader.py index 398bb36602..e2c91123db 100644 --- a/synapse/app/client_reader.py +++ b/synapse/app/client_reader.py @@ -31,6 +31,7 @@ from synapse.http.site import SynapseSite from synapse.metrics import RegistryProxy from synapse.metrics.resource import METRICS_PREFIX, MetricsResource from synapse.replication.slave.storage._base import BaseSlavedStore +from synapse.replication.slave.storage.account_data import SlavedAccountDataStore from synapse.replication.slave.storage.appservice import SlavedApplicationServiceStore from synapse.replication.slave.storage.client_ips import SlavedClientIpStore from synapse.replication.slave.storage.directory import DirectoryStore @@ -58,6 +59,7 @@ logger = logging.getLogger("synapse.app.client_reader") class ClientReaderSlavedStore( + SlavedAccountDataStore, SlavedEventStore, SlavedKeyStore, RoomStore, |