diff options
author | Jorik Schellekens <joriks@matrix.org> | 2019-07-08 14:00:36 +0100 |
---|---|---|
committer | Jorik Schellekens <joriks@matrix.org> | 2019-07-23 16:05:21 +0100 |
commit | 1ed790d67a2751feaf5da368ff3d31077219e39d (patch) | |
tree | 1c29c66265971213134d3dea074814510f5c3155 | |
parent | Opentracing across streams (diff) | |
download | synapse-1ed790d67a2751feaf5da368ff3d31077219e39d.tar.xz |
Some tracing
-rw-r--r-- | synapse/handlers/device.py | 6 |
1 files changed, 6 insertions, 0 deletions
diff --git a/synapse/handlers/device.py b/synapse/handlers/device.py index 746e2179e1..dc8938e510 100644 --- a/synapse/handlers/device.py +++ b/synapse/handlers/device.py @@ -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): |