diff options
| author | Erik Johnston <erikj@jki.re> | 2018-02-27 11:34:26 +0000 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2018-02-27 11:34:26 +0000 |
| commit | 3594dbc6dc088b2a02eb9906a391602ad4213639 (patch) | |
| tree | 98c8c8e1e1f883d052721c31767f920cb6e66a01 /synapse/replication | |
| parent | Merge pull request #2903 from matrix-org/erikj/split_roommember_store (diff) | |
| parent | Fix missing invalidations for receipt storage (diff) | |
| download | synapse-3594dbc6dc088b2a02eb9906a391602ad4213639.tar.xz | |
Merge pull request #2904 from matrix-org/erikj/receipt_cache_invalidation
Fix missing invalidations for receipt storage
Diffstat (limited to 'synapse/replication')
| -rw-r--r-- | synapse/replication/slave/storage/receipts.py | 2 |
1 files changed, 2 insertions, 0 deletions
diff --git a/synapse/replication/slave/storage/receipts.py b/synapse/replication/slave/storage/receipts.py index f0e29e9836..1647072f65 100644 --- a/synapse/replication/slave/storage/receipts.py +++ b/synapse/replication/slave/storage/receipts.py @@ -53,6 +53,8 @@ class SlavedReceiptsStore(ReceiptsWorkerStore, BaseSlavedStore): self.get_last_receipt_event_id_for_user.invalidate( (user_id, room_id, receipt_type) ) + self._invalidate_get_users_with_receipts_in_room(room_id, receipt_type, user_id) + self.get_receipts_for_room.invalidate((room_id, receipt_type)) def process_replication_rows(self, stream_name, token, rows): if stream_name == "receipts": |