diff options
Diffstat (limited to 'synapse/handlers/federation.py')
| -rw-r--r-- | synapse/handlers/federation.py | 11 |
1 files changed, 6 insertions, 5 deletions
diff --git a/synapse/handlers/federation.py b/synapse/handlers/federation.py index eca75f1108..3fcd5f3db4 100644 --- a/synapse/handlers/federation.py +++ b/synapse/handlers/federation.py @@ -1726,15 +1726,16 @@ class FederationHandler: await self._device_handler.handle_room_un_partial_stated(room_id) logger.info("Clearing partial-state flag for %s", room_id) - success = await self.store.clear_partial_state_room(room_id) - if success: + new_stream_id = await self.store.clear_partial_state_room(room_id) + if new_stream_id is not None: logger.info("State resync complete for %s", room_id) 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() + + await self._notifier.on_un_partial_stated_room( + room_id, new_stream_id + ) # TODO(faster_joins) update room stats and user directory? # https://github.com/matrix-org/synapse/issues/12814 |