summary refs log tree commit diff
path: root/synapse/handlers/federation_event.py
diff options
context:
space:
mode:
authorEric Eastwood <erice@element.io>2021-11-02 21:26:52 -0500
committerEric Eastwood <erice@element.io>2021-11-02 21:27:08 -0500
commit5db717ab8569a9e16cfbb589d50f80bceed00d2a (patch)
tree2084292f4545b51fbdefff6b9e6883e1d52114ee /synapse/handlers/federation_event.py
parentRemove the new backfill implementation and pull some good parts of the refactor (diff)
downloadsynapse-5db717ab8569a9e16cfbb589d50f80bceed00d2a.tar.xz
Always process marker events regardless if backfilled
Before, we could rely on the `connected_insertion_event_query`
to navigate the and find the historical branch. But now
we solely rely on the marker event to point out the
historical branch. So we need to make sure to add
the insertion event extremeties whenever we see a marker event.
Whether it be a live event or backfilled.
Diffstat (limited to 'synapse/handlers/federation_event.py')
-rw-r--r--synapse/handlers/federation_event.py10
1 files changed, 5 insertions, 5 deletions
diff --git a/synapse/handlers/federation_event.py b/synapse/handlers/federation_event.py

index f219a0f42a..9ccf99f5c5 100644 --- a/synapse/handlers/federation_event.py +++ b/synapse/handlers/federation_event.py
@@ -752,9 +752,9 @@ class FederationEventHandler: backfilled: True if this is part of a historical batch of events (inhibits notification to clients, and validation of device keys.) """ - - logger.info( - "backfill events=%s", + logger.debug( + "processing pulled backfilled=%s events=%s", + backfilled, [ "event_id=%s,depth=%d,body=%s,prevs=%s\n" % ( @@ -1146,6 +1146,8 @@ class FederationEventHandler: await self._run_push_actions_and_persist_event(event, context, backfilled) + await self._handle_marker_event(origin, event) + if backfilled: return @@ -1223,8 +1225,6 @@ class FederationEventHandler: event.sender, ) - await self._handle_marker_event(origin, event) - async def _resync_device(self, sender: str) -> None: """We have detected that the device list for the given user may be out of sync, so we try and resync them.