summary refs log tree commit diff
path: root/synapse/federation/federation_server.py
diff options
context:
space:
mode:
authorRichard van der Hoff <1389908+richvdh@users.noreply.github.com>2021-09-29 11:59:43 +0100
committerGitHub <noreply@github.com>2021-09-29 11:59:43 +0100
commit176aa55fd5971610727cb10372faf521542653d9 (patch)
tree36f560e385679213b8d717d1b2d7f55f90f6ddfe /synapse/federation/federation_server.py
parentUse direct references for configuration variables (part 6). (#10916) (diff)
downloadsynapse-176aa55fd5971610727cb10372faf521542653d9.tar.xz
add event id to logcontext when handling incoming PDUs (#10936)
Diffstat (limited to '')
-rw-r--r--synapse/federation/federation_server.py5
1 files changed, 4 insertions, 1 deletions
diff --git a/synapse/federation/federation_server.py b/synapse/federation/federation_server.py
index 638959cbec..83f11d6b88 100644
--- a/synapse/federation/federation_server.py
+++ b/synapse/federation/federation_server.py
@@ -1008,7 +1008,10 @@ class FederationServer(FederationBase):
             async with lock:
                 logger.info("handling received PDU: %s", event)
                 try:
-                    await self._federation_event_handler.on_receive_pdu(origin, event)
+                    with nested_logging_context(event.event_id):
+                        await self._federation_event_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