summary refs log tree commit diff
path: root/synapse/federation
diff options
context:
space:
mode:
authorJorik Schellekens <joriksch@gmail.com>2019-08-22 11:28:12 +0100
committerGitHub <noreply@github.com>2019-08-22 11:28:12 +0100
commit9a6f2be5724bb0ed53a4b04e7fbb7ccee39050bd (patch)
tree4ef024998d593df4487a02c72143ba42e18c3585 /synapse/federation
parentAdd missing index on users_in_public_rooms. (#5894) (diff)
downloadsynapse-9a6f2be5724bb0ed53a4b04e7fbb7ccee39050bd.tar.xz
Opentrace e2e keys (#5855)
Add opentracing tags and logs for e2e keys
Diffstat (limited to 'synapse/federation')
-rw-r--r--synapse/federation/federation_server.py3
1 files changed, 3 insertions, 0 deletions
diff --git a/synapse/federation/federation_server.py b/synapse/federation/federation_server.py
index d216c46dfe..9286ca3202 100644
--- a/synapse/federation/federation_server.py
+++ b/synapse/federation/federation_server.py
@@ -43,6 +43,7 @@ from synapse.federation.persistence import TransactionActions
 from synapse.federation.units import Edu, Transaction
 from synapse.http.endpoint import parse_server_name
 from synapse.logging.context import nested_logging_context
+from synapse.logging.opentracing import log_kv, trace
 from synapse.logging.utils import log_function
 from synapse.replication.http.federation import (
     ReplicationFederationSendEduRestServlet,
@@ -507,6 +508,7 @@ class FederationServer(FederationBase):
     def on_query_user_devices(self, origin, user_id):
         return self.on_query_request("user_devices", user_id)
 
+    @trace
     @defer.inlineCallbacks
     @log_function
     def on_claim_client_keys(self, origin, content):
@@ -515,6 +517,7 @@ class FederationServer(FederationBase):
             for device_id, algorithm in device_keys.items():
                 query.append((user_id, device_id, algorithm))
 
+        log_kv({"message": "Claiming one time keys.", "user, device pairs": query})
         results = yield self.store.claim_e2e_one_time_keys(query)
 
         json_result = {}