summary refs log tree commit diff
diff options
context:
space:
mode:
authorJorik Schellekens <joriks@matrix.org>2019-07-08 14:00:36 +0100
committerJorik Schellekens <joriks@matrix.org>2019-07-23 16:05:21 +0100
commit1ed790d67a2751feaf5da368ff3d31077219e39d (patch)
tree1c29c66265971213134d3dea074814510f5c3155
parentOpentracing across streams (diff)
downloadsynapse-1ed790d67a2751feaf5da368ff3d31077219e39d.tar.xz
Some tracing
-rw-r--r--synapse/handlers/device.py6
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):