summary refs log tree commit diff
path: root/synapse/replication
diff options
context:
space:
mode:
authorErik Johnston <erik@matrix.org>2018-03-01 11:59:16 +0000
committerErik Johnston <erik@matrix.org>2018-03-01 11:59:16 +0000
commit89f90d808ad923374a204377b0bc8ed15a9385a9 (patch)
tree44bb8a1bd532cf98eafc571834006875f84a1340 /synapse/replication
parentMake repl send_event idempotent and retry on timeouts (diff)
downloadsynapse-89f90d808ad923374a204377b0bc8ed15a9385a9.tar.xz
Add some logging
Diffstat (limited to 'synapse/replication')
-rw-r--r--synapse/replication/http/send_event.py2
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)