summary refs log tree commit diff
path: root/synapse/handlers/federation.py
diff options
context:
space:
mode:
authorBrendan Abolivier <babolivier@matrix.org>2019-02-13 20:51:47 +0000
committerBrendan Abolivier <babolivier@matrix.org>2019-02-13 20:54:34 +0000
commit94342ce65da99ce3840653a17bffcafe2982b1e4 (patch)
tree3bbc0196bb93347c1a829cd4e0aaaa571db8f3b0 /synapse/handlers/federation.py
parentFix unnoticed merge conflict (diff)
downloadsynapse-94342ce65da99ce3840653a17bffcafe2982b1e4.tar.xz
Add logging for meshsim
Diffstat (limited to 'synapse/handlers/federation.py')
-rw-r--r--synapse/handlers/federation.py10
1 files changed, 10 insertions, 0 deletions
diff --git a/synapse/handlers/federation.py b/synapse/handlers/federation.py
index c07ba171e3..b16097caa2 100644
--- a/synapse/handlers/federation.py
+++ b/synapse/handlers/federation.py
@@ -68,6 +68,7 @@ from ._base import BaseHandler
 
 logger = logging.getLogger(__name__)
 
+pdu_logger = logging.getLogger("synapse.federation.pdu_destination_logger")
 
 def shortstr(iterable, maxitems=5):
     """If iterable has maxitems or fewer, return the stringification of a list
@@ -176,6 +177,15 @@ class FederationHandler(BaseHandler):
                 or pdu.internal_metadata.is_outlier()
             )
         )
+        pdu_logger.info(
+            "ReceivedPDU",
+            extra={
+                "event_id": pdu.event_id, "room_id": pdu.room_id,
+                "origin": origin, "already_seen": already_seen,
+                "server": self.server_name,
+            },
+        )
+
         if already_seen:
             logger.debug("[%s %s]: Already seen pdu", room_id, event_id)
             return