MirrorHub/synapse
0
0
Fork 1
mirror of https://mau.dev/maunium/synapse.git synced 2024-12-30 03:43:55 +01:00
Code Issues Projects Releases Wiki Activity

Mark remote device list updates as already handled (#12557)

Browse source
This commit is contained in:
Erik Johnston 2022-04-26 17:07:21 +01:00 committed by GitHub
parent 6d89f1239c
commit f59e3f4c90
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
4 changed files with 7 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

1
changelog.d/12557.misc Normal file
View file

@ -0,0 +1 @@
Reduce unnecessary work when handling remote device list updates.

5
synapse/handlers/device.py
View file

@ -505,8 +505,9 @@ class DeviceHandler(DeviceWorkerHandler):
"device_list_key", position, users={user_id}, rooms=room_ids
)
# We may need to do some processing asynchronously.
self._handle_new_device_update_async()
# We may need to do some processing asynchronously for local user IDs.
if self.hs.is_mine_id(user_id):
self._handle_new_device_update_async()
async def notify_user_signature_update(
self, from_user_id: str, user_ids: List[str]

3
synapse/storage/databases/main/devices.py
View file

@ -1748,7 +1748,8 @@ class DeviceStore(DeviceWorkerStore, DeviceBackgroundUpdateStore):
device_id,
room_id,
stream_id,
False,
# We only need to calculate outbound pokes for local users
not self.hs.is_mine_id(user_id),
encoded_context,
)
for room_id in room_ids

2
tests/storage/test_devices.py
View file

@ -29,7 +29,7 @@ class DeviceStoreTestCase(HomeserverTestCase):
for device_id in device_ids:
stream_id = self.get_success(
self.store.add_device_change_to_streams(
"user_id", [device_id], ["!some:room"]
user_id, [device_id], ["!some:room"]
)
)