mirrors/synapse
1
0
Fork 0
mirror of https://github.com/element-hq/synapse.git synced 2024-12-22 04:34:28 +03:00
Code Issues Projects Releases Packages Wiki Activity

Some tracing

Browse source
This commit is contained in:
Jorik Schellekens 2019-07-08 14:00:36 +01:00
parent 957cd77e95
commit 1ed790d67a
1 changed files with 6 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

6
synapse/handlers/device.py
View file

@ -397,6 +397,7 @@ class DeviceHandler(DeviceWorkerHandler):
else:
raise
@opentracing.trace_defered_function
@measure_func("notify_device_update")
@defer.inlineCallbacks
def notify_device_update(self, user_id, device_ids):
@ -412,6 +413,8 @@ class DeviceHandler(DeviceWorkerHandler):
hosts.update(get_domain_from_id(u) for u in users_who_share_room)
hosts.discard(self.server_name)
opentracing.set_tag("hosts to update", hosts)
position = yield self.store.add_device_change_to_streams(
user_id, device_ids, list(hosts)
)
@ -431,6 +434,9 @@ class DeviceHandler(DeviceWorkerHandler):
)
for host in hosts:
self.federation_sender.send_device_messages(host)
opentracing.log_kv(
{"message": "sent device update to host", "host": host}
)
@defer.inlineCallbacks
def on_federation_query_user_devices(self, user_id):