Fixed undefined variable error in catchup (#9664)

Broke in #9640 Co-authored-by: Patrick Cloke <[email protected]>
matrix-org · Mar 24, 2021 · c602ba8 · c602ba8
1 parent c2d4bd6
commit c602ba8
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 0 deletions.
diff --git a/changelog.d/9664.misc b/changelog.d/9664.misc
@@ -0,0 +1 @@
+Improve performance of federation catch up by sending events the latest events in the room to the remote, rather than just the last event sent by the local server.
diff --git a/synapse/federation/sender/per_destination_queue.py b/synapse/federation/sender/per_destination_queue.py
@@ -480,6 +480,8 @@ async def _catch_up_transmission_loop(self) -> None:
                     # the other sending servers are up).
                     if new_pdus:
                         room_catchup_pdus = new_pdus
+                    else:
+                        room_catchup_pdus = [pdu]
 
                 logger.info(
                     "Catching up rooms to %s: %r", self._destination, pdu.room_id
Original file line number	Diff line number	Diff line change
		@@ -0,0 +1 @@
		Improve performance of federation catch up by sending events the latest events in the room to the remote, rather than just the last event sent by the local server.