summary refs log tree commit diff
path: root/synapse/replication
diff options
context:
space:
mode:
authorErik Johnston <erik@matrix.org>2018-02-21 15:19:54 +0000
committerErik Johnston <erik@matrix.org>2018-02-21 15:19:54 +0000
commitfaeb369f158a3ca6ba8f48ca1d551b2b53f4c53a (patch)
treed311bc0f5dda76560c21e19094165ac4a1e91891 /synapse/replication
parentMerge pull request #2893 from matrix-org/erikj/delete_from_staging_fed (diff)
downloadsynapse-faeb369f158a3ca6ba8f48ca1d551b2b53f4c53a.tar.xz
Fix missing invalidations for receipt storage
Diffstat (limited to 'synapse/replication')
-rw-r--r--synapse/replication/slave/storage/receipts.py2
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":