kaslo/synapse
1
0
Fork 0
Code Wiki Activity

Merge branch 'erikj/device_list_sync_perf' into matrix-org-hotfixes

Browse Source
This commit is contained in:
Olivier 'reivilibre
2024-05-18 16:33:57 +01:00
parent 233e25e193 6a0d2dc6fc
commit 122d190e40
1 changed files with 6 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files
synapse/replication/tcp/client.py
+6 -5
View File
@@ -114,11 +114,12 @@ class ReplicationDataHandler:
"""
all_room_ids: Set[str] = set()
if stream_name == DeviceListsStream.NAME:
prev_token = self.store.get_device_stream_token()
all_room_ids = await self.store.get_all_device_list_changes(
prev_token, token
)
self.store.device_lists_in_rooms_have_changed(all_room_ids, token)
if any(row.entity.startswith("@") and not row.is_signature for row in rows):
prev_token = self.store.get_device_stream_token()
all_room_ids = await self.store.get_all_device_list_changes(
prev_token, token
)
self.store.device_lists_in_rooms_have_changed(all_room_ids, token)
self.store.process_replication_rows(stream_name, instance_name, token, rows)
# NOTE: this must be called after process_replication_rows to ensure any