diff options
author | Erik Johnston <erikj@matrix.org> | 2023-11-29 18:21:30 +0000 |
---|---|---|
committer | GitHub <noreply@github.com> | 2023-11-29 18:21:30 +0000 |
commit | a14678492eed5482312000bd7423f765680e4afc (patch) | |
tree | 008397e775c290f79c4eff9bfcf965d32e285a29 /synapse/handlers | |
parent | Add a workflow to try and automatically fixup a PR (#16704) (diff) | |
download | synapse-a14678492eed5482312000bd7423f765680e4afc.tar.xz |
Reduce DB load when forget on leave setting is disabled (#16668)
* Reduce DB load when forget on leave setting is disabled * Newsfile
Diffstat (limited to 'synapse/handlers')
-rw-r--r-- | synapse/handlers/room_member.py | 11 |
1 files changed, 8 insertions, 3 deletions
diff --git a/synapse/handlers/room_member.py b/synapse/handlers/room_member.py index eddc2af9ba..00c2dd854d 100644 --- a/synapse/handlers/room_member.py +++ b/synapse/handlers/room_member.py @@ -2111,9 +2111,14 @@ class RoomForgetterHandler(StateDeltasHandler): self.pos = room_max_stream_ordering if not self._hs.config.room.forget_on_leave: - # Update the processing position, so that if the server admin turns the - # feature on at a later date, we don't decide to forget every room that - # has ever been left in the past. + # Update the processing position, so that if the server admin turns + # the feature on at a later date, we don't decide to forget every + # room that has ever been left in the past. + # + # We wait for a short time so that we don't "tight" loop just + # keeping the table up to date. + await self._clock.sleep(0.5) + self.pos = self._store.get_room_max_stream_ordering() await self._store.update_room_forgetter_stream_pos(self.pos) return |