diff options
| author | Brendan Abolivier <babolivier@matrix.org> | 2020-09-04 10:19:42 +0100 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2020-09-04 10:19:42 +0100 |
| commit | 9f8abdcc3828e942f09cc62e29dff93dbaa01ec7 (patch) | |
| tree | 5811a075386a883af3e9da43c6123beb812d70c4 /synapse/handlers/room_member.py | |
| parent | Add type hints to more handlers (#8244) (diff) | |
| download | synapse-9f8abdcc3828e942f09cc62e29dff93dbaa01ec7.tar.xz | |
Revert "Add experimental support for sharding event persister. (#8170)" (#8242)
* Revert "Add experimental support for sharding event persister. (#8170)" This reverts commit 82c1ee1c22a87b9e6e3179947014b0f11c0a1ac3. * Changelog
Diffstat (limited to 'synapse/handlers/room_member.py')
| -rw-r--r-- | synapse/handlers/room_member.py | 7 |
1 files changed, 7 insertions, 0 deletions
diff --git a/synapse/handlers/room_member.py b/synapse/handlers/room_member.py index e5cb3c2d5c..a7962b0ada 100644 --- a/synapse/handlers/room_member.py +++ b/synapse/handlers/room_member.py @@ -82,6 +82,13 @@ class RoomMemberHandler(object): self._enable_lookup = hs.config.enable_3pid_lookup self.allow_per_room_profiles = self.config.allow_per_room_profiles + self._event_stream_writer_instance = hs.config.worker.writers.events + self._is_on_event_persistence_instance = ( + self._event_stream_writer_instance == hs.get_instance_name() + ) + if self._is_on_event_persistence_instance: + self.persist_event_storage = hs.get_storage().persistence + self._join_rate_limiter_local = Ratelimiter( clock=self.clock, rate_hz=hs.config.ratelimiting.rc_joins_local.per_second, |