summary refs log tree commit diff
path: root/synapse/replication/slave
diff options
context:
space:
mode:
authorErik Johnston <erik@matrix.org>2020-03-18 10:13:55 +0000
committerErik Johnston <erik@matrix.org>2020-03-18 10:13:55 +0000
commit6e6476ef07c2d72fbea85603f2eb2a61a6866732 (patch)
tree659fce3ef13f42f87c4d6e4547b417a56d8b73b7 /synapse/replication/slave
parentMerge branch 'develop' of github.com:matrix-org/synapse into erikj/fixup_devi... (diff)
downloadsynapse-6e6476ef07c2d72fbea85603f2eb2a61a6866732.tar.xz
Comments from review
Diffstat (limited to 'synapse/replication/slave')
-rw-r--r--synapse/replication/slave/storage/devices.py3
1 files changed, 3 insertions, 0 deletions
diff --git a/synapse/replication/slave/storage/devices.py b/synapse/replication/slave/storage/devices.py
index 01a4f85884..23b1650e41 100644
--- a/synapse/replication/slave/storage/devices.py
+++ b/synapse/replication/slave/storage/devices.py
@@ -72,6 +72,9 @@ class SlavedDeviceStore(EndToEndKeyWorkerStore, DeviceWorkerStore, BaseSlavedSto
 
     def _invalidate_caches_for_devices(self, token, rows):
         for row in rows:
+            # The entities are either user IDs (starting with '@') whose devices
+            # have changed, or remote servers that we need to tell about
+            # changes.
             if row.entity.startswith("@"):
                 self._device_list_stream_cache.entity_has_changed(row.entity, token)
                 self.get_cached_devices_for_user.invalidate((row.entity,))