diff options
| author | Erik Johnston <erikj@matrix.org> | 2023-10-25 16:16:19 +0100 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2023-10-25 16:16:19 +0100 |
| commit | ba47fea5286e084ec70d568aa62eb4820b857c47 (patch) | |
| tree | 6e2c608feb1ea0c23b2b9cc40d11211cc3a10aa5 /synapse/handlers/sync.py | |
| parent | Fix tests on Twisted trunk. (#16528) (diff) | |
| download | synapse-ba47fea5286e084ec70d568aa62eb4820b857c47.tar.xz | |
Allow multiple workers to write to receipts stream. (#16432)
Fixes #16417
Diffstat (limited to 'synapse/handlers/sync.py')
| -rw-r--r-- | synapse/handlers/sync.py | 7 |
1 files changed, 6 insertions, 1 deletions
diff --git a/synapse/handlers/sync.py b/synapse/handlers/sync.py index f131c0e8e0..f75c1548ca 100644 --- a/synapse/handlers/sync.py +++ b/synapse/handlers/sync.py @@ -57,6 +57,7 @@ from synapse.types import ( DeviceListUpdates, JsonDict, JsonMapping, + MultiWriterStreamToken, MutableStateMap, Requester, RoomStreamToken, @@ -477,7 +478,11 @@ class SyncHandler: event_copy = {k: v for (k, v) in event.items() if k != "room_id"} ephemeral_by_room.setdefault(room_id, []).append(event_copy) - receipt_key = since_token.receipt_key if since_token else 0 + receipt_key = ( + since_token.receipt_key + if since_token + else MultiWriterStreamToken(stream=0) + ) receipt_source = self.event_sources.sources.receipt receipts, receipt_key = await receipt_source.get_new_events( |