diff options
| author | Richard van der Hoff <1389908+richvdh@users.noreply.github.com> | 2021-08-19 18:05:12 +0100 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2021-08-19 17:05:12 +0000 |
| commit | e81d62009ee091d69d56bca702ba0edd39becb1c (patch) | |
| tree | b20911f0ffe6e7fee3a022ff658144bf73cdce58 /synapse/federation | |
| parent | Extract `_resolve_state_at_missing_prevs` (#10624) (diff) | |
| download | synapse-e81d62009ee091d69d56bca702ba0edd39becb1c.tar.xz | |
Split `on_receive_pdu` in half (#10640)
Here we split on_receive_pdu into two functions (on_receive_pdu and process_pulled_event), rather than having both cases in the same method. There's a tiny bit of overlap, but not that much.
Diffstat (limited to 'synapse/federation')
| -rw-r--r-- | synapse/federation/federation_server.py | 4 |
1 files changed, 1 insertions, 3 deletions
diff --git a/synapse/federation/federation_server.py b/synapse/federation/federation_server.py index afd8f8580a..e1b58d40c5 100644 --- a/synapse/federation/federation_server.py +++ b/synapse/federation/federation_server.py @@ -1005,9 +1005,7 @@ class FederationServer(FederationBase): async with lock: logger.info("handling received PDU: %s", event) try: - await self.handler.on_receive_pdu( - origin, event, sent_to_us_directly=True - ) + await self.handler.on_receive_pdu(origin, event) except FederationError as e: # XXX: Ideally we'd inform the remote we failed to process # the event, but we can't return an error in the transaction |