Log origin and stats of incoming transactions

10 years ago · b21d015c55
parent e70e8e053e
commit b21d015c55
1 changed files with 8 additions and 0 deletions
--- a/synapse/federation/transport/server.py
+++ b/synapse/federation/transport/server.py
@ -196,6 +196,14 @@ class FederationSendServlet(BaseFederationServlet):
                transaction_id, str(transaction_data)
            )

+            logger.info(
+                "Received txn %s from %s. (PDUs: %d, EDUs: %d, failures: %d)",
+                transaction_id, origin,
+                len(transaction_data.get("pdus", [])),
+                len(transaction_data.get("edus", [])),
+                len(transaction_data.get("failures", [])),
+            )
+
            # We should ideally be getting this from the security layer.
            # origin = body["origin"]