diff options
| author | Erik Johnston <erik@matrix.org> | 2020-02-28 11:24:05 +0000 |
|---|---|---|
| committer | Erik Johnston <erik@matrix.org> | 2020-02-28 11:25:34 +0000 |
| commit | 9ce4e344a808e15a36a2d9ea03b77ebfc6ac7fe2 (patch) | |
| tree | 50df94a33c6d12b1129e89cbf63819f0c570091b /synapse/app/generic_worker.py | |
| parent | Change device lists stream to have one row per id. (diff) | |
| download | synapse-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.py | 2 |
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) |