diff options
| author | Erik Johnston <erik@matrix.org> | 2018-03-01 11:59:16 +0000 |
|---|---|---|
| committer | Erik Johnston <erik@matrix.org> | 2018-03-01 11:59:16 +0000 |
| commit | 89f90d808ad923374a204377b0bc8ed15a9385a9 (patch) | |
| tree | 44bb8a1bd532cf98eafc571834006875f84a1340 /synapse/replication/http/send_event.py | |
| parent | Make repl send_event idempotent and retry on timeouts (diff) | |
| download | synapse-89f90d808ad923374a204377b0bc8ed15a9385a9.tar.xz | |
Add some logging
Diffstat (limited to 'synapse/replication/http/send_event.py')
| -rw-r--r-- | synapse/replication/http/send_event.py | 2 |
1 files changed, 2 insertions, 0 deletions
diff --git a/synapse/replication/http/send_event.py b/synapse/replication/http/send_event.py index 73cd3d91d9..f490622b63 100644 --- a/synapse/replication/http/send_event.py +++ b/synapse/replication/http/send_event.py @@ -72,6 +72,7 @@ def send_event_to_master(client, host, port, requester, event, context, break except CodeMessageException as e: if e.code != 504: + logger.warn("send_event request timed out") raise # If we timed out we probably don't need to worry about backing @@ -118,6 +119,7 @@ class ReplicationSendEventRestServlet(RestServlet): def on_PUT(self, request, event_id): result = self.response_cache.get(event_id) if not result: + logger.warn("Returning cached response") result = self.response_cache.set( event_id, preserve_fn(self._handle_request)(request) |