diff options
| author | reivilibre <oliverw@matrix.org> | 2022-12-05 13:07:55 +0000 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2022-12-05 13:07:55 +0000 |
| commit | 501f62d1a62296f79e46e1bd60dc5d1a8b28847d (patch) | |
| tree | 7a9bd41e1f0857fa79e7a001af767e4404bd52ed /synapse/handlers/federation.py | |
| parent | Fix push.enabled config documentation (#14619) (diff) | |
| download | synapse-501f62d1a62296f79e46e1bd60dc5d1a8b28847d.tar.xz | |
Faster remote room joins: stream the un-partial-stating of rooms over replication. [rei:frrj/streams/unpsr] (#14473)
Diffstat (limited to 'synapse/handlers/federation.py')
| -rw-r--r-- | synapse/handlers/federation.py | 4 |
1 files changed, 4 insertions, 0 deletions
diff --git a/synapse/handlers/federation.py b/synapse/handlers/federation.py index d92582fd5c..3398fcaf7d 100644 --- a/synapse/handlers/federation.py +++ b/synapse/handlers/federation.py @@ -152,6 +152,7 @@ class FederationHandler: self._federation_event_handler = hs.get_federation_event_handler() self._device_handler = hs.get_device_handler() self._bulk_push_rule_evaluator = hs.get_bulk_push_rule_evaluator() + self._notifier = hs.get_notifier() self._clean_room_for_join_client = ReplicationCleanRoomRestServlet.make_client( hs @@ -1692,6 +1693,9 @@ class FederationHandler: self._storage_controllers.state.notify_room_un_partial_stated( room_id ) + # Poke the notifier so that other workers see the write to + # the un-partial-stated rooms stream. + self._notifier.notify_replication() # TODO(faster_joins) update room stats and user directory? # https://github.com/matrix-org/synapse/issues/12814 |