summary refs log tree commit diff
path: root/synapse/replication/http
diff options
context:
space:
mode:
authorJorik Schellekens <joriksch@gmail.com>2019-09-05 17:44:55 +0100
committerGitHub <noreply@github.com>2019-09-05 17:44:55 +0100
commitf7c873a64355506221648d55d64023c83d43f618 (patch)
tree4fa1eedd0ebda87bf213880dd3e1878a76b9235a /synapse/replication/http
parentGracefully handle log context slips and missing opentracing import errors. (#... (diff)
downloadsynapse-f7c873a64355506221648d55d64023c83d43f618.tar.xz
Trace how long it takes for the send trasaction to complete, including retrys (#5986)
Diffstat (limited to 'synapse/replication/http')
-rw-r--r--synapse/replication/http/_base.py7
1 files changed, 6 insertions, 1 deletions
diff --git a/synapse/replication/http/_base.py b/synapse/replication/http/_base.py
index afc9a8ff29..03560c1f0e 100644
--- a/synapse/replication/http/_base.py
+++ b/synapse/replication/http/_base.py
@@ -28,7 +28,11 @@ from synapse.api.errors import (
     RequestSendFailed,
     SynapseError,
 )
-from synapse.logging.opentracing import inject_active_span_byte_dict, trace_servlet
+from synapse.logging.opentracing import (
+    inject_active_span_byte_dict,
+    trace,
+    trace_servlet,
+)
 from synapse.util.caches.response_cache import ResponseCache
 from synapse.util.stringutils import random_string
 
@@ -129,6 +133,7 @@ class ReplicationEndpoint(object):
 
         client = hs.get_simple_http_client()
 
+        @trace(opname="outgoing_replication_request")
         @defer.inlineCallbacks
         def send_request(**kwargs):
             data = yield cls._serialize_payload(**kwargs)