summary refs log tree commit diff
path: root/synapse/app/generic_worker.py
diff options
context:
space:
mode:
authorErik Johnston <erik@matrix.org>2020-02-28 11:24:05 +0000
committerErik Johnston <erik@matrix.org>2020-02-28 11:25:34 +0000
commit9ce4e344a808e15a36a2d9ea03b77ebfc6ac7fe2 (patch)
tree50df94a33c6d12b1129e89cbf63819f0c570091b /synapse/app/generic_worker.py
parentChange device lists stream to have one row per id. (diff)
downloadsynapse-9ce4e344a808e15a36a2d9ea03b77ebfc6ac7fe2.tar.xz
Change device list replication to match new semantics.
Instead of sending down batches of user ID/host tuples, send down a row
per entity (user ID or host).
Diffstat (limited to 'synapse/app/generic_worker.py')
-rw-r--r--synapse/app/generic_worker.py2
1 files changed, 1 insertions, 1 deletions
diff --git a/synapse/app/generic_worker.py b/synapse/app/generic_worker.py
index b2c764bfe8..561a6f4b22 100644
--- a/synapse/app/generic_worker.py
+++ b/synapse/app/generic_worker.py
@@ -774,7 +774,7 @@ class FederationSenderHandler(object):
 
         # ... as well as device updates and messages
         elif stream_name == DeviceListsStream.NAME:
-            hosts = {row.destination for row in rows}
+            hosts = {row.entity for row in rows if not row.entity.startswith("@")}
             for host in hosts:
                 self.federation_sender.send_device_messages(host)