diff options
| author | Erik Johnston <erik@matrix.org> | 2020-02-27 13:07:39 +0000 |
|---|---|---|
| committer | Erik Johnston <erik@matrix.org> | 2020-03-20 15:31:43 +0000 |
| commit | 7233d386902d03bf2785d19324289f535ca7a81d (patch) | |
| tree | 5e38859cc3c957416c2ab733c8b879d16d653738 /synapse/app | |
| parent | Remove concept of a non-limited stream. (#7011) (diff) | |
| download | synapse-7233d386902d03bf2785d19324289f535ca7a81d.tar.xz | |
Move stream fetch DB queries to worker stores.
Diffstat (limited to 'synapse/app')
| -rw-r--r-- | synapse/app/generic_worker.py | 3 |
1 files changed, 3 insertions, 0 deletions
diff --git a/synapse/app/generic_worker.py b/synapse/app/generic_worker.py index cdc078cf11..5caba3160c 100644 --- a/synapse/app/generic_worker.py +++ b/synapse/app/generic_worker.py @@ -390,6 +390,9 @@ class GenericWorkerTyping(object): self._room_serials[row.room_id] = token self._room_typing[row.room_id] = row.user_ids + def get_current_token(self) -> int: + return self._latest_room_serial + class GenericWorkerSlavedStore( # FIXME(#3714): We need to add UserDirectoryStore as we write directly |