Skip to content
This repository has been archived by the owner on Apr 26, 2024. It is now read-only.

Commit

Permalink
Process the cache stream first for incoming replication
Browse files Browse the repository at this point in the history
Receiving new data about e.g. events, read receipts, etc., is likely to
result in some database actions. An example of that is that we send a
push on new read receipts, which involves calculating a badge from
unread counts. Because of this, we probably want to process cache
updates/invalidations first so these actions are not using outdated
cache data. In the previous example, we want to make sure we invalidate
the cache on calculating the unread count for the user/room the read
receipt is for before sending a push.
  • Loading branch information
babolivier committed Jul 8, 2020
1 parent aa0a56b commit 420573a
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion synapse/replication/tcp/streams/__init__.py
Original file line number Diff line number Diff line change
Expand Up @@ -48,14 +48,14 @@
STREAMS_MAP = {
stream.NAME: stream
for stream in (
CachesStream,
EventsStream,
BackfillStream,
PresenceStream,
TypingStream,
ReceiptsStream,
PushRulesStream,
PushersStream,
CachesStream,
PublicRoomsStream,
DeviceListsStream,
ToDeviceStream,
Expand Down

0 comments on commit 420573a

Please sign in to comment.