diff options
| author | Jorik Schellekens <joriksch@gmail.com> | 2019-09-05 17:44:55 +0100 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2019-09-05 17:44:55 +0100 |
| commit | f7c873a64355506221648d55d64023c83d43f618 (patch) | |
| tree | 4fa1eedd0ebda87bf213880dd3e1878a76b9235a /synapse/replication/http | |
| parent | Gracefully handle log context slips and missing opentracing import errors. (#... (diff) | |
| download | synapse-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.py | 7 |
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) |