diff options
author | David Robertson <davidr@element.io> | 2022-01-20 13:38:44 +0000 |
---|---|---|
committer | GitHub <noreply@github.com> | 2022-01-20 13:38:44 +0000 |
commit | f160fe18e3cc5604375f491300d12dd5c7e9b9b2 (patch) | |
tree | 4027aaff31d9f01313f2311e8cd65d8c3ffeed7c /synapse/federation/transport | |
parent | Allow overriding the complement ref. (#11766) (diff) | |
download | synapse-f160fe18e3cc5604375f491300d12dd5c7e9b9b2.tar.xz |
Debug for device lists updates (#11760)
Debug for #8631. I'm having a hard time tracking down what's going wrong in that issue. In the reported example, I could see server A sending federation traffic to server B and all was well. Yet B reports out-of-sync device updates from A. I couldn't see what was _in_ the events being sent from A to B. So I have added some crude logging to track - when we have updates to send to a remote HS - the edus we actually accumulate to send - when a federation transaction includes a device list update edu - when such an EDU is received This is a bit of a sledgehammer.
Diffstat (limited to 'synapse/federation/transport')
-rw-r--r-- | synapse/federation/transport/server/federation.py | 15 |
1 files changed, 15 insertions, 0 deletions
diff --git a/synapse/federation/transport/server/federation.py b/synapse/federation/transport/server/federation.py index 77bfd88ad0..beadfa422b 100644 --- a/synapse/federation/transport/server/federation.py +++ b/synapse/federation/transport/server/federation.py @@ -36,6 +36,7 @@ from synapse.util.ratelimitutils import FederationRateLimiter from synapse.util.versionstring import get_version_string logger = logging.getLogger(__name__) +issue_8631_logger = logging.getLogger("synapse.8631_debug") class BaseFederationServerServlet(BaseFederationServlet): @@ -95,6 +96,20 @@ class FederationSendServlet(BaseFederationServerServlet): len(transaction_data.get("edus", [])), ) + if issue_8631_logger.isEnabledFor(logging.DEBUG): + DEVICE_UPDATE_EDUS = {"m.device_list_update", "m.signing_key_update"} + device_list_updates = [ + edu.content + for edu in transaction_data.get("edus", []) + if edu.edu_type in DEVICE_UPDATE_EDUS + ] + if device_list_updates: + issue_8631_logger.debug( + "received transaction [%s] including device list updates: %s", + transaction_id, + device_list_updates, + ) + except Exception as e: logger.exception(e) return 400, {"error": "Invalid transaction"} |